conduktor.io ↗

KIP-92 — Add per partition lag metrics to KafkaConsumer

Accepted ConsumerMetrics

KIP-92 adds per-partition consumer lag metrics (`records-lag`, `records-lag-avg`, `records-lag-max`) scoped by topic and partition to the `consumer-fetch-manager-metrics` group in `KafkaConsumer`. The existing metric only exposes the maximum lag across all assigned partitions, making it impossible to detect which specific partition is falling behind.

Details

AuthorJiangjie Qin
StatusAccepted
JIRAKAFKA-4381
WikiView on Apache Wiki
Created2016-11-13
Last Modified2017-01-06
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.