[ https://issues.apache.org/jira/browse/KAFKA-1335?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=14553213#comment-14553213 ]
Jason Gustafson commented on KAFKA-1335: ---------------------------------------- Hey [~onurkaraman], I'm looking at this issue. Just wanted to clarify that part 2 is what is referred to above: bq. 2) Adding the rebalance logic on the consumer upon topic change / error code from coordinator. I can pick this up if you haven't begun working on it yet. > Add rebalancing logic to the coordinator / consumer > --------------------------------------------------- > > Key: KAFKA-1335 > URL: https://issues.apache.org/jira/browse/KAFKA-1335 > Project: Kafka > Issue Type: Sub-task > Components: consumer > Affects Versions: 0.9.0 > Reporter: Neha Narkhede > Assignee: Guozhang Wang > > This implements the group management protocol. This will be a tricky and > potentially large change since it will involve implementing the group > management protocol, which include: > 1) Adding the rebalance logic on the coordinator that can be triggered from > membership change (either through failure detector or join group requests) > and topic / partition ZK listener fires. > 2) Adding the rebalance logic on the consumer upon topic change / error code > from coordinator. -- This message was sent by Atlassian JIRA (v6.3.4#6332)