conduktor.io ↗

Kafka ConsumerGroupDescribe Changelog — Protocol Version History

What is ConsumerGroupDescribe?

Describes consumer groups using the new protocol (KIP-848) via kafka-consumer-groups.sh --describe. Returns per-member assignment details with the group epoch. A rapidly incrementing epoch means members are joining/leaving frequently, which is normal during scaling but abnormal in steady state.

VersionKafkaChanges
ConsumerGroupDescribeRequest
v03.7
+ GroupIds []string
+ IncludeAuthorizedOperations bool
~ Flexible encoding enabled FLEXIBLE
v14.0
adds MemberType field to ConsumerGroupDescribeResponse (KIP-1099). For ConsumerGroupDescribeRequest, version 1 is same as version 0.
ConsumerGroupDescribeResponse
v03.7
+ ThrottleTimeMs int32
+ Groups []DescribedGroup
+ ErrorCode int16
+ ErrorMessage string
+ GroupId string
+ GroupState string
+ GroupEpoch int32
+ AssignmentEpoch int32
+ AssignorName string
+ Members []Member
+ MemberId string
+ InstanceId string
+ RackId string
+ MemberEpoch int32
+ ClientId string
+ ClientHost string
+ SubscribedTopicNames []string
+ SubscribedTopicRegex string
+ Assignment Assignment
+ TopicPartitions []TopicPartitions
+ TopicId uuid
+ TopicName string
+ Partitions []int32
+ TargetAssignment Assignment
+ TopicPartitions []TopicPartitions
+ TopicId uuid
+ TopicName string
+ Partitions []int32
+ AuthorizedOperations int32
~ Flexible encoding enabled FLEXIBLE
v14.0
+ MemberType int8
adds MemberType field (KIP-1099).