You are viewing a plain text version of this content. The canonical link for it is here.

Posted to jira@kafka.apache.org by "Lianet Magrans (Jira)" <ji...@apache.org> on 2024/11/28 14:35:00 UTC

[jira] [Created] (KAFKA-18116) Admin LeaveGroup fails for static consumer group member

Lianet Magrans created KAFKA-18116:
--------------------------------------

             Summary: Admin LeaveGroup fails for static consumer group member 
                 Key: KAFKA-18116
                 URL: https://issues.apache.org/jira/browse/KAFKA-18116
             Project: Kafka
          Issue Type: Bug
          Components: group-coordinator
            Reporter: Lianet Magrans
            Assignee: David Jacot
             Fix For: 4.0.0


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 



--
This message was sent by Atlassian Jira
(v8.20.10#820010)