KIP-545 — support automated consumer offset sync across clusters in MM 2.0
Accepted Kafka 2.7 MirrorMaker
KIP-545 adds a `sync.group.offsets.enabled` MirrorMaker 2 configuration that, when combined with `emit.checkpoints.enabled`, periodically writes translated consumer offsets into the target cluster's `__consumer_offsets` topic automatically. Previously, offset translation from the source cluster was available via `MirrorClient.remoteConsumerOffsets()` but had to be driven by external tooling; without automatic sync, consumers failing over to the target cluster cannot resume from their last committed position without manual intervention.
Details
| Author | Ning Zhang |
| Status | Accepted |
| Kafka Version | 2.7 |
| JIRA | KAFKA-9076 |
| Wiki | View on Apache Wiki |
| Created | 2019-10-23 |
| Last Modified | 2020-07-19 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.