[
https://issues.apache.org/jira/browse/KAFKA-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jiangjie Qin updated KAFKA-1839:
--------------------------------
Assignee: Jiangjie Qin
Status: Patch Available (was: Open)
> 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
> Assignee: Jiangjie Qin
> Attachments: KAFKA-1839_2015-01-20_11:49:12.patch
>
>
> 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)
