KIP-1226 — Introducing Share Partition Lag Persistence and Retrieval

Accepted Kafka 4.2 Consumer

Introduces share partition lag computation and persistence so that operators can query per-partition consumption progress for share groups via DescribeShareGroupOffsets and kafka-share-groups.sh. Share groups previously had no per-partition lag metric because their non-sequential, multi-consumer consumption model makes lag more complex than a simple end offset minus committed offset.

Protocol Impact

WriteShareGroupState v1 · ReadShareGroupStateSummary v1 · DescribeShareGroupOffsets v1

Details