clusters = dc1, dc2, dc3 tasks.max = 2 dc1.bootstrap.servers = kafka-dc1:19092 dc2.bootstrap.servers = kafka-dc2:19093 dc3.bootstrap.servers = kafka-dc3:19094 dc1.group.id=mm2-dc1 dc2.group.id=mm2-dc2 dc3.group.id=mm2-dc3 replication.factor=1 checkpoints.topic.replication.factor=1 heartbeats.topic.replication.factor=1 offset-syncs.topic.replication.factor=1 offset.storage.replication.factor=1 status.storage.replication.factor=1 config.storage.replication.factor=1 dc1->dc3.enabled = true dc1->dc3.topics = test_topic_dc1 dc2->dc3.enabled = true dc2->dc3.topics = test_topic_dc2 dc3->dc2 = false dc3->dc1 = false