What is WriteShareGroupState?
Durably persists delivery state updates after consumers acknowledge records. This write is on the critical path of ShareAcknowledge, so high latency here (slow disk on the coordinator broker) directly impacts acknowledgement throughput.
| Version | Kafka | Changes |
|---|---|---|
| WriteShareGroupStateRequest | ||
| v0 | 3.9 | + GroupId string+ Topics []WriteStateData+ TopicId uuid+ Partitions []PartitionData+ Partition int32+ StateEpoch int32+ LeaderEpoch int32+ StartOffset int64+ StateBatches []StateBatch+ FirstOffset int64+ LastOffset int64+ DeliveryState int8+ DeliveryCount int16~ Flexible encoding enabled FLEXIBLE is the initial version (KIP-932). |
| v1 | 4.2 | + DeliveryCompleteCount int32introduces DeliveryCompleteCount (KIP-1226). |
| WriteShareGroupStateResponse | ||
| v0 | 3.9 | + Results []WriteStateResult+ TopicId uuid+ Partitions []PartitionResult+ Partition int32+ ErrorCode int16+ ErrorMessage string~ Flexible encoding enabled FLEXIBLE is the initial version (KIP-932). |
| v1 | 4.2 | introduces DeliveryCompleteCount in the request (KIP-1226). |