The new consumers' group metadata is now stored in Kafka instead of
zookeeper.
The group coordinator will wait for the JoinGroupRequest from all the
consumers in the current generation before it moves on to ask group leader
assign the partitions. After the consumers passes this barrier, supposedly
Hi,
after reviewed Kafka 0.9.0 code, I have a rebalance question:
coordinator will choose a client as leader to execute assign, after
transfer it to coordinator, when assignments are Propagate to each member in
consumer group,how can it sure one partition is only owned by a consum
