THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
| Code Block | ||||||
|---|---|---|---|---|---|---|
| ||||||
public class MemberMetadata {
/**
* The topics that the group member is subscribed to.
*/
public Set<String> topics() {
return topics;
}
/**
* The user data of the group member.
*/
public ByteBuffer userData() {
return userData;
}
/**
* The topic partitions owned by the group member.
*/
public Set<TopicPartition> ownedPartitions() {
return ownedPartitions;
} |
Proposed Changes
The ConsumerGroupDescription returned by KafkaAdminClient#describeConsumerGroups includes the metadata of each member of the group. The MemberDescription class is extended to carry on the MemberMetadata as described above. The metadata is populated only when the group is a consumer group similarly to the assignments.
...