conduktor.io ↗

Kafka InitializeShareGroupState Changelog — Protocol Version History

What is InitializeShareGroupState?

Sets up the persistent state partition in __share_group_state before a share group can start consuming (internal, not called by operators). Failures here (e.g., authorization issues on the internal topic) prevent share groups from starting.

VersionKafkaChanges
InitializeShareGroupStateRequest
v03.9
+ GroupId string
+ Topics []InitializeStateData
+ TopicId uuid
+ Partitions []PartitionData
+ Partition int32
+ StateEpoch int32
+ StartOffset int64
~ Flexible encoding enabled FLEXIBLE
InitializeShareGroupStateResponse
v03.9
+ Results []InitializeStateResult
+ TopicId uuid
+ Partitions []PartitionResult
+ Partition int32
+ ErrorCode int16
+ ErrorMessage string
~ Flexible encoding enabled FLEXIBLE