Kafka MirrorMaker 2.0 duplicate each messages – Debian
I am trying to replicate Kafka cluster with MirrorMaker 2.0. I am using following mm2.properties: name = mirror-site1-site2 topics = .* connector.class = org.apache.kafka.connect.mirror.MirrorSourceConnector tasks.max = 1 plugin.path=/usr/share/java/kafka/plugin clusters = site1, site2 # for demo, source and target clusters are…