Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

Code Block
languagejava
titleMemberDescription
linenumberstrue
public class MemberDescription {
    private final String memberId;
    private final Optional<String> groupInstanceId;
    private final String clientId;
    private final String host;
    private final MemberAssignment assignment;
    private final Optional<MemberAssignment> targetAssignment;
    private final Optional<Integer> memberEpoch;
    private final String protocol;

	// ...

	/**
	 * The epoch of the group member.
	 */
	public Optional<Integer> memberEpoch() {
		return memberEpoch;
	}

    /**
     * The protocol of the group member.
     */
    public String protocol() {
        return protocol;
    }
}

RPCs

ConsumerGroupDescribeRequest

Bump validVersions to "0-1".

Code Block
titleConsumerGroupDescribeRequest
{
  "apiKey": 69,
  "type": "request",
  "listeners": ["broker"],
  "name": "ConsumerGroupDescribeRequest",
  "validVersions": "0-1",  <-- bump to 0-1 
  "flexibleVersions": "0+",
  "fields": [
    { "name": "GroupIds", "type": "[]string", "versions": "0+", "entityType": "groupId",
      "about": "The ids of the groups to describe" },
    { "name": "IncludeAuthorizedOperations", "type": "bool", "versions": "0+",
      "about": "Whether to include authorized operations." }
  ]
}


ConsumerGroupDescribeResponse

...

Code Block
$ bin/kafka-consumer-groups.sh --bootstrap-server localhost:9092 --describe --group my-group --members --verbose
GROUP		CONSUMER-ID				HOST			CLIENT-ID			#PARTITIONS		CURRENT-EPOCH	CURRENT-ASSIGNMENT			TARGET-EPOCH	TARGET-ASSIGNMENT			PROTOCOL
my-group	T4tbGKsvT7CtsxVBH5J2QQ	/127.0.0.1		consumer-my-group-1	4				1				my_topic:0,1;new_topic:0,1	1				my_topic:0,1;new_topic:0,1	consumer

Following table lists protocol meaning.

ProtocolMeaning
"classic"

A member in classic group.

A member with non-null classicMemberMetadata in consumer group.

"consumer"A member with null classicMemberMetadata in consumer group.
"share"A member in share group.

--describe --offsets --verbose

...