conduktor.io ↗

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

AuthorElkhan Eminov
StatusDiscussion
JIRAKAFKA-14112
WikiView on Apache Wiki
Created2023-08-13
Last Modified2024-02-20
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.