You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Jiangjie Qin (JIRA)" <ji...@apache.org> on 2015/01/20 20:49:36 UTC

[jira] [Updated] (KAFKA-1839) Adding an afterRebalance callback to the ConsumerRebalanceListener of ZookeeperConsumerConnector

     [ https://issues.apache.org/jira/browse/KAFKA-1839?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Jiangjie Qin updated KAFKA-1839:
--------------------------------
    Attachment: KAFKA-1839_2015-01-20_11:49:12.patch

> 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
>         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)