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
| Author | Walker Carlson |
| Status | Accepted |
| Kafka Version | 3.0 |
| JIRA | KAFKA-12347 |
| Wiki | View on Apache Wiki |
| Created | 2021-02-05 |
| Last Modified | 2021-05-10 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.