Affects Version/s: 0.8.0
Fix Version/s: 0.8.0
Due to the watcher and zk data structure mismatch, consumer will not rebalance upon topic partition change. Details:
ZK data structure for topic partitions:
When new partitions are added, it will change the data in /brokers/topics/[topic-name], however the ZK client is watching on child change of /brokers/topics/[topic-name], which will always be a single child 'partitions'.
Proposal: add a data change listener, which will trigger rebalance upon data changes on /brokers/topics/[topic-name].
|Status||Resolved [ 5 ]||Closed [ 6 ]|
|Status||Open [ 1 ]||Resolved [ 5 ]|
|Fix Version/s||0.8 [ 12317244 ]|
|Resolution||Fixed [ 1 ]|