Jiangjie Qin created KAFKA-1839:
-----------------------------------
Summary: Adding an afterRebalance callback to the
ConsumerRebalanceListener of ZookeeperConsumerConnector
Key: KAFKA-1839
URL: https://issues.apache.org/jira/browse/KAFKA-1839
Project: Kafka
Issue Type: Improvement
Reporter: Jiangjie Qin
Currently there is only a beforeReleasePartition callback in consumer rebalance
listener of ZookeeperConsumerConnector. It is useful to have an afterRebalance
callback with new partition assignment passed in. There are some use cases
where knowing the topic partition changes is useful (e.g. mirror maker can
create same number of partitions for new topic in target cluster). The new
consumer will have such callback but probably won't be production ready very
soon. Because adding this callback is not much amount of work so we can do this
as a short term solution.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
