[GitHub] [kafka] jeffkbkim commented on pull request #11571: KAFKA-13496: add reason to LeaveGroupRequest

[GitBox <gi...@apache.org>]

jeffkbkim commented on pull request #11571:
URL: https://github.com/apache/kafka/pull/11571#issuecomment-988460630


   tests calling `adminClient.removeMembersFromConsumerGroup` are failing:
   ```
   ERROR [KafkaApi-2] Unexpected error handling request RequestHeader(apiKey=LEAVE_GROUP, apiVersion=5, clientId=adminclient-1, correlationId=30) -- LeaveGroupRequestData(groupId='test_group_id', memberId='', members=[MemberIdentity(memberId='', groupInstanceId='invalid-instance-id', reason='null')]) with context RequestContext(header=RequestHeader(apiKey=LEAVE_GROUP, apiVersion=5, clientId=adminclient-1, correlationId=30), connectionId='127.0.0.1:58238-127.0.0.1:58241-0', clientAddress=/127.0.0.1, principal=User:ANONYMOUS, listenerName=ListenerName(PLAINTEXT), securityProtocol=PLAINTEXT, clientInformation=ClientInformation(softwareName=apache-kafka-java, softwareVersion=unknown), fromPrivilegedListener=true, principalSerde=Optional[org.apache.kafka.common.security.authenticator.DefaultKafkaPrincipalBuilder@5d777a17]) (kafka.server.KafkaApis:76)
   org.apache.kafka.common.errors.UnsupportedVersionException: Can't size version 5 of MemberResponse
   ```
   
   i'm not sure i understand the exception. LEAVE_GROUP/API_VERSION=5 requests are valid.
   
   the error is from `LeaveGroupResponseData.addSize` - why is the response validating the request api version?


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: jira-unsubscribe@kafka.apache.org

For queries about this service, please contact Infrastructure at:
users@infra.apache.org