Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-14048 The Next Generation of the Consumer Rebalance Protocol
  3. KAFKA-16258

Stale member should trigger onPartitionsLost when leaving group

    XMLWordPrintableJSON

Details

    Description

      When the poll timer expires, the new consumer proactively leaves the group and clears its assignments, but it should also invoke the onPartitionsLost callback. The legacy coordinator does the following sequence on poll timer expiration: send leave group request (here), invoke onPartitionsLost, and when it completes it clears the assignment (onJoinPrepare here).

      This issue is most probably what is causing the failures in the integration tests that fail expecting callbacks when the poll interval expires (like https://issues.apache.org/jira/browse/KAFKA-16008)

      Attachments

        Issue Links

          Activity

            People

              lianetm Lianet Magrans
              lianetm Lianet Magrans
              Votes:
              0 Vote for this issue
              Watchers:
              2 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: