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 consumer
because of consumer’s execute orders.I can not find a owner node in kafka 0.9
zk.
because the execute order of the two consumers, may be at a fixed time, A
consumer owned a partition at last generation, and B consumer owned this
partition at this partition, when this occurs, how it resolve?
