KIP-971 — Expose replication-record-lag MirrorMaker2 metric
Discussion MirrorMakerMetrics
Adds replication-record-lag metrics (max/min/avg) to MirrorMaker2's MirrorSourceTask, computed as the difference between the source partition's LEO and the last replicated offset (LRO). No built-in metric existed to directly quantify how many records remained to be replicated, forcing operators to infer lag from byte-lag proxies.
Details
| Author | Elkhan Eminov |
| Status | Discussion |
| JIRA | KAFKA-14112 |
| Wiki | View on Apache Wiki |
| Created | 2023-08-13 |
| Last Modified | 2024-02-20 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.