jiafu1115 opened a new pull request, #20691: URL: https://github.com/apache/kafka/pull/20691
Hi Team: Currently, the AdminClient’s describeConsumerGroups API returns a MemberDescription that does not include rack information, even though the underlying ConsumerGroupDescribeResponse protocol already supports a rackId field. This causes users to be unable to retrieve member rack information through the Admin API. Rack information is crucial for: > Monitoring and visualization tools > Operational analysis of rack distribution > Diagnosing rack-aware assignment issues In addition, StreamsGroupMemberDescription already includes the rackId, so adding it here would make the behavior more consistent. BTW, I have currently implemented our AZ/Rack analysis using a workaround — passing the rack information into the clientId field and parsing it afterward. kafkaConsumerConfig.customConfig(ConsumerConfig.CLIENT_ID_CONFIG, generateClientIdWithRack(ip, rack)); <img width="1092" height="764" alt="image" src="https://github.com/user-attachments/assets/b53acde9-3c67-4daf-b6fa-52bbe2415a0b"; /> So I propose this change with tiny code change to support this feature. Thanks for review! -- 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: [email protected] For queries about this service, please contact Infrastructure at: [email protected]
