[
https://issues.apache.org/jira/browse/KAFKA-286?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Jun Rao updated KAFKA-286:
--------------------------
Attachment: kafka-286_v2.patch
That's a good point. What can happen is that we may delete ZK paths that c1
didn't successfully own in step 2, if rebalance fails. Added patch v2 that
deletes all temporarily owned ZK paths in reflectPartitionOwnershipDecision, if
we can't own everything. I think this fix addresses this issue.
> 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
