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

AbstractCoordinator wakeup during rebalance can cause spurious rebalances

    XMLWordPrintableJSON

    Details

    • Type: Bug
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.9.0.0, 0.9.0.1
    • Fix Version/s: 0.10.0.0
    • Component/s: consumer, KafkaConnect
    • Labels:
      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

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

              Dates

              • Created:
                Updated:
                Resolved: