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

Admin LeaveGroup fails for static consumer group member

    XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Blocker
    • Resolution: Fixed
    • None
    • 4.0.0
    • group-coordinator

    Description

      A LeaveGroup request sent by an admin client returns UNKNOWN_MEMBER_ID for a static consumer group member, due to this validation:

      https://github.com/apache/kafka/blob/d334f60944fa51622f0035039fa36d6d98405c59/group-coordinator/src/main/java/org/apache/kafka/coordinator/group/GroupMetadataManager.java#L6132

      This does not allow admin removal of static consumer members. The behaviour is covered in PlaintextAdminIntegrationTest, currently passing for the classic consumer but failing for the new async consumer on this assertion.

      https://github.com/apache/kafka/blob/d334f60944fa51622f0035039fa36d6d98405c59/core/src/test/scala/integration/kafka/api/PlaintextAdminIntegrationTest.scala#L2031 

      Attachments

        Issue Links

          Activity

            People

              dajac David Jacot
              lianetm Lianet Magrans
              Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: