conduktor.io ↗

KIP-592 — Replicate mirrormaker topics from earliest

Discussion MirrorMaker

Changes MirrorMaker 1.0's default `auto.offset.reset` from `latest` to `earliest` so that replication topics are consumed from the beginning. The current `latest` default causes data loss when MirrorMaker is subscribed via regex patterns and a matching topic is created while MirrorMaker is running—records produced before MirrorMaker catches up are permanently skipped.

Details

AuthorJeff Widman
StatusDiscussion
JIRAKAFKA-4668
WikiView on Apache Wiki
Created2020-04-11
Last Modified2020-05-04
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.