KIP-1098 — Reverse Checkpointing in MirrorMaker

Discussion MirrorMakerConsumer

Extends MirrorMaker2 checkpointing to support reverse replication so that consumer group offsets made on the downstream cluster are checkpointed back upstream, enabling minimal reprocessing on failback after a failover. In bidirectional replication, the standard checkpoint flow only covers failover (upstream→downstream direction), leaving consumers that progressed on the downstream cluster unable to resume accurately when switching back.

Details