conduktor.io ↗

Kafka StreamsGroupDescribe Changelog — Protocol Version History

What is StreamsGroupDescribe?

Shows Kafka Streams groups managed under the broker-side assignor (KIP-1071), with per-member task assignments (active, standby, warm-up) and the group epoch. Rapidly incrementing epochs indicate frequent membership changes, which could signal instability.

VersionKafkaChanges
StreamsGroupDescribeRequest
v04.1
+ GroupIds []string
+ IncludeAuthorizedOperations bool
~ Flexible encoding enabled FLEXIBLE
StreamsGroupDescribeResponse
v04.1
+ ThrottleTimeMs int32
+ Groups []DescribedGroup
+ ErrorCode int16
+ ErrorMessage string
+ GroupId string
+ GroupState string
+ GroupEpoch int32
+ AssignmentEpoch int32
+ Topology Topology
+ Epoch int32
+ Subtopologies []Subtopology
+ SubtopologyId string
+ SourceTopics []string
+ RepartitionSinkTopics []string
+ StateChangelogTopics []TopicInfo
+ Name string
+ Partitions int32
+ ReplicationFactor int16
+ TopicConfigs []KeyValue
+ Key string
+ Value string
+ RepartitionSourceTopics []TopicInfo
+ Name string
+ Partitions int32
+ ReplicationFactor int16
+ TopicConfigs []KeyValue
+ Key string
+ Value string
+ Members []Member
+ MemberId string
+ MemberEpoch int32
+ InstanceId string
+ RackId string
+ ClientId string
+ ClientHost string
+ TopologyEpoch int32
+ ProcessId string
+ UserEndpoint Endpoint
+ Host string
+ Port uint16
+ ClientTags []KeyValue
+ Key string
+ Value string
+ TaskOffsets []TaskOffset
+ SubtopologyId string
+ Partition int32
+ Offset int64
+ TaskEndOffsets []TaskOffset
+ SubtopologyId string
+ Partition int32
+ Offset int64
+ Assignment Assignment
+ ActiveTasks []TaskIds
+ SubtopologyId string
+ Partitions []int32
+ StandbyTasks []TaskIds
+ SubtopologyId string
+ Partitions []int32
+ WarmupTasks []TaskIds
+ SubtopologyId string
+ Partitions []int32
+ TargetAssignment Assignment
+ ActiveTasks []TaskIds
+ SubtopologyId string
+ Partitions []int32
+ StandbyTasks []TaskIds
+ SubtopologyId string
+ Partitions []int32
+ WarmupTasks []TaskIds
+ SubtopologyId string
+ Partitions []int32
+ IsClassic bool
+ AuthorizedOperations int32
~ Flexible encoding enabled FLEXIBLE