[
https://issues.apache.org/jira/browse/KAFKA-286?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=13217395#comment-13217395
]
Neha Narkhede commented on KAFKA-286:
-------------------------------------
Yes, missed the fact that after releasing the partitions, it also gets deleted
from the passed in topic registry. Looks good now, we will have to be careful
about keeping this topic registry cache in sync at all times though. I like the
idea of refreshing the cache from ZK during each rebalance attempt, but we can
look into that later.
+1 on v2.
> consumer sometimes don't release partition ownership properly in ZK during
> rebalance
> ------------------------------------------------------------------------------------
>
> Key: KAFKA-286
> URL: https://issues.apache.org/jira/browse/KAFKA-286
> Project: Kafka
> Issue Type: Bug
> Components: core
> Reporter: Jun Rao
> Assignee: Jun Rao
> Fix For: 0.7.1
>
> Attachments: kafka-286.patch, kafka-286_v2.patch
>
>
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators:
https://issues.apache.org/jira/secure/ContactAdministrators!default.jspa
For more information on JIRA, see: http://www.atlassian.com/software/jira
