conduktor.io ↗

KIP-690 — Add additional configuration to control MirrorMaker 2 internal topics naming convention

Accepted Kafka 3.1 MirrorMaker

KIP-690 adds `heartbeatsTopic()`, `checkpointsTopic(clusterAlias)`, and `offsetSyncsTopic(clusterAlias)` methods to the `ReplicationPolicy` interface so MirrorMaker 2 internal topic names can be overridden via `replication.policy.separator` or a custom `ReplicationPolicy` implementation. The previous hardcoded names (`heartbeats`, `<alias>.checkpoint.internal`, `mm2-offset-syncs.<alias>.internal`) could not be changed, blocking deployment in clusters that enforce topic naming conventions or prohibit auto-topic creation.

Details

AuthorOmnia Ibrahim
StatusAccepted
Kafka Version3.1
JIRAKAFKA-10777
WikiView on Apache Wiki
Created2020-12-01
Last Modified2023-07-05
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.