[jira] [Created] (KAFKA-3528) AbstractCoordinator wakeup during rebalance can cause spurious rebalances

["Jason Gustafson (JIRA)" <ji...@apache.org>]

Jason Gustafson created KAFKA-3528:
--------------------------------------

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