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
| Author | Jiangjie Qin |
| Status | Accepted |
| JIRA | KAFKA-4381 |
| Wiki | View on Apache Wiki |
| Created | 2016-11-13 |
| Last Modified | 2017-01-06 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.