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

Jason Gustafson updated KAFKA-3528:
-----------------------------------
    Status: Patch Available  (was: Open)

> AbstractCoordinator wakeup during rebalance can cause spurious rebalances
> -------------------------------------------------------------------------
>
>                 Key: KAFKA-3528
>                 URL: https://issues.apache.org/jira/browse/KAFKA-3528
>             Project: Kafka
>          Issue Type: Bug
>          Components: consumer, KafkaConnect
>    Affects Versions: 0.9.0.1, 0.9.0.0
>            Reporter: Jason Gustafson
>            Assignee: Jason Gustafson
>
> If the user calls wakeup() while a rebalance is pending, the join/sync will 
> be left on the wire. Although the requests will eventually complete on a 
> later call to poll(), since we have aborted the call to ensureActiveGroup(), 
> the onJoinComplete() callback will never be invoked. This causes a spurious 
> rebalance on the next poll() since we never received the assignment for the 
> joined generation. This also affects Kafka Connect, which depends internally 
> on the group management protocol and uses wakeup to break from poll() in 
> order to handle requests.



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)

Reply via email to