conduktor.io ↗

KIP-3 — Mirror Maker Enhancement

Accepted Kafka 1.0 MirrorMaker

KIP-3 redesigns MirrorMaker to use `producer.send()` with a callback and defer consumer offset commits until producer acknowledgment, eliminating the data loss window between consumer commit and producer delivery. The original MirrorMaker committed consumer offsets before confirming producer delivery, so a crash between those two points silently dropped messages.

Details

AuthorJiangjie Qin
StatusAccepted
Kafka Version1.0
JIRAKAFKA-1997
WikiView on Apache Wiki
Created2015-01-21
Last Modified2015-07-18
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.