Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-3528

AbstractCoordinator wakeup during rebalance can cause spurious rebalances

    XMLWordPrintableJSON

Details

    • Bug
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • 0.9.0.0, 0.9.0.1
    • 0.10.0.0
    • connect, consumer
    • None

    Description

      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.

      Attachments

        Activity

          People

            hachikuji Jason Gustafson
            hachikuji Jason Gustafson
            Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: