pubsub/kafkapubsub: add a test for rebalancing and multiple partitions (#2451)
pubsub/kafkapubsub: add a test for rebalancing and multiple partitions (#2451)


google/go-cloud,google/go-cloud,google/go-cloud