KIP-1292 — New MirrorMaker2 Connector for syncing consumer offsets

Discussion MirrorMakerConsumer

Introduces a dedicated MirrorMaker 2 connector for consumer group offset synchronization that is separate from the existing MirrorCheckpointConnector, providing real-time offset sync via the consumer offsets topic rather than periodic checkpoint emission. MirrorCheckpointConnector conflates checkpoint generation with offset sync and commits offsets only periodically, creating a lag window during which a failover to the target cluster results in reprocessing.

Details