Hi Team, We are running Apache MirrorMaker 2 (MM2) in active/active mode using connect-mirrormaker.sh on a 6-node Apache Kafka cluster (v3.8.1). The source cluster is running Kafka 2.8.0. Below is a summary of our setup and the issue we’re facing: Setup MM2 is running on the destination Kafka clu…

no worries thanks for the update not sure what we could in addition to be honest, looks a bit strange just to be sure: the connect-distributed is running on kafka 3.8.1 right? nothing running on the legacy 2.8.1?

yes, connect-distributed is running on kafka 3.8.1 here’s properties ## Mirror Maker Configurations # name of the connector, e.g. "us-west->us-east" name = {{ source_cluster_name }}-{{ dest_cluster_name }} # Maximum number of tasks to use for this connector tasks.max = 12 num.stream.threads = 6 …

so if my understanding is correct it’s still blocking you , right? or is is just an error without harming your setup? did you consider to raise an issue here? - ASF JIRA

your kafka connect setup is fine?

Yes, it’s just an error with no impact on our setup — there’s no lag observed on the replicated topics. We can raise a JIRA and track it further once we recheck our firewall policies for port 8083 used in internode communication. Regarding your question on the Kafka Connect setup: Yes, it’s workin…

[image] Ismail: Regarding your question on the Kafka Connect setup: Yes, it’s working as expected — we’re running the connect-mirror-maker.sh process across all 6 nodes. understood though you mentioned the connect distributed as well, right? where is this located? [image] Ismail: You c…

@mmuehlbeyer i was on vacation, sorry for the delayed response we’re running the connect-mirror-maker.sh process, not the connect distributed.

no worries. are you able to test the connect-mirror-maker one?

Yes, it’s working as expected — we’re running the connect-mirror-maker.sh process across all 6 nodes. But we occasionally face a corrupt record exception, which disrupts replication from the affected node until we restart all MirrorMaker processes at once. This typically happens once or twice a mont…

MM2 Stops Replicating on Corrupt Record – Need Guidance for Active/Active Setup

Kafka Connect

mmuehlbeyer 18 August 2025 06:39 30

sorry misspelled my question above

would like to if you have the chance to test with connect-mirror-distributed

Topic		Replies	Views
Apache Kafka MirrorMaker 2 (MM2) bidirectional replication A <-> B Cluster Replication	9	726	31 March 2025
Mirrormaker2 creating heartbeats topics recursively in loop in active-active mode Kafka Connect	52	2477	16 July 2024
MirrorMaker Endless loop Cluster Replication	5	5127	6 December 2022
Setup Bidirectional Kafka Mirrormaker2 replication Kafka Connect	1	3155	15 November 2023
MirrorMaker 2: topic gets created on target but records stay (or loop) on source Cluster Replication	0	64	24 April 2025

MM2 Stops Replicating on Corrupt Record – Need Guidance for Active/Active Setup

Related topics