conduktor.io ↗

KIP-715 — Expose Committed offset in streams

Accepted Kafka 3.0 StreamsMetrics

Adds `committedOffsets()`, `endOffsets()`, and `timeCurrentIdlingStarted()` to `TaskMetadata` so health-check services can track per-task consumer progress without embedding Kafka clients. Kafka Streams embeds multiple consumer clients internally, making it impossible to derive task-level lag from the standard committed-offset APIs used for standalone consumers.

Details

AuthorWalker Carlson
StatusAccepted
Kafka Version3.0
JIRAKAFKA-12347
WikiView on Apache Wiki
Created2021-02-05
Last Modified2021-05-10
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.