Hi, I was very much relieved to see MirrorMaker2 working in my sandbox for a major project where we are migrating out of cluster A to cluster B for a better hardware. To my surprise, it fails to migrate any user topics when I used it in one of our real pre-prod environments where we have real topics. Let me give a brief about my environment -
ENV A OS: Ubuntu 18 3 node Kafka cluster 3 node ZooKeeper cluster ENV B OS: Ubuntu 18 3 node Kafka cluster 3 node ZooKeeper cluster Kafka version: Confluent kafka 5.5 Zk version: 3.5.8 here is the mm2.properties I used in my sandbox fyr where replication is working fine - # mm2.propertiesclusters = A, BA.bootstrap.servers = Ahost1:port, Ahost2:port, Ahost3:portB.bootstrap.servers = Bhost1:port, Bhost2:port, Bhost3:portA->B.enabled = trueB->A.enabled = falsereplication.factor=3checkpoints.topic.replication.factor=3heartbeats.topic.replication.factor=3offset-syncs.topic.replication.factor=3replication.policy.separator=source.cluster.alias=target.cluster.alias=replication.policy.class= io.strimzi.kafka.connect.mirror.IdentityReplicationPolicytopics = .*groups = .*emit.checkpoints.interval.seconds = 10security.protocol=SASL_PLAINTEXTsasl.mechanism=PLAINsasl.jaas.config=org.apache.kafka.common.security.plain.PlainLoginModule required \ username="vvvvv" \ password="ccccccccc"; I used the same configuration in my pre-prod environment where I have to successfully test the cutover procedure inorder to move to PROD within the speculated tight timeline but it fails to replicate any data. The only job it is successfully doing is creating these 3 below topics in both A and B clusters - mm2-configs.n.internalmm2-offsets.n.internalmm2-status.n.internal where n is A in source and B in target And the kafka logs does not have anything to help me with troubleshooting neither have any monitoring tools to track the sync progress if at all it is happening. Could you please help me here - 1. How to enable logging for mirrormaker 2. How can I successfully monitor it 3. How can I make it work Note: Its not a network traffic issue as I have verified telnet from A<-->B and it is working. Thanks!
