# MirrorMaker 2 replication error

**URL:** <https://forum.confluent.io/t/mirrormaker-2-replication-error/12332>\
**Category:** Confluent Cloud\
**Created:** [9 October 2024 07:31 UTC](https://forum.confluent.io/t/mirrormaker-2-replication-error/12332 "2024-10-09T07:31:16Z")\
**Posts on this page:** 1\
**Page:** 1

<div class="post-metadata">

**Author:** ![dammin](https://avatars.discourse-cdn.com/v4/letter/d/b9e5f3/32.png) [@dammin](https://forum.confluent.io/u/dammin)\
**Post date:** [9 October 2024 07:31 UTC](https://forum.confluent.io/t/mirrormaker-2-replication-error/12332/1 "2024-10-09T07:31:16Z")

</div>

Hello experts

I’m trying to replicate between two Confluent cloud Standard clusters using MirrorMaker 2 (I am aware of cluster linking, we need MMK in our instance).

The error I am receiving is:

> Could not create topic confluent\_cloud\_source.topic\_name. … org.apache.kafka.common.errors.PolicyViolationException: Topic replication factor must be 3

The replication factor is 3 by default, and I can’t change it even if I wanted.

Connection to the clusters is fine, I can see the heartbeat and checkpoint topics being created.

Here is my config:

> # Clusters
> 
> clusters = confluent\_cloud\_source, confluent\_cloud\_target
> 
> # Confluent Cloud Source Cluster Configuration
> 
> confluent\_cloud\_source.bootstrap.servers = ppp-55555.eastus.azure.confluent.cloud:9092  
> confluent\_cloud\_source.security.protocol = SASL\_SSL  
> confluent\_cloud\_source.sasl.mechanism = PLAIN  
> confluent\_cloud\_source.sasl.jaas.config = org.apache.kafka.common.security.plain.PlainLoginModule required   
> username=“asdasdasd”   
> password=“asdasdasdasd”;  
> confluent\_cloud\_source.replication.factor = 3  
> confluent\_cloud\_source.ssl.endpoint.identification.algorithm = https  
> confluent\_cloud\_source.client.dns.lookup = use\_all\_dns\_ips
> 
> # Confluent Cloud Target Cluster Configuration
> 
> confluent\_cloud\_target.bootstrap.servers = ppp-55555.switzerlandnorth.azure.confluent.cloud:9092  
> confluent\_cloud\_target.security.protocol = SASL\_SSL  
> confluent\_cloud\_target.sasl.mechanism = PLAIN  
> confluent\_cloud\_target.sasl.jaas.config = org.apache.kafka.common.security.plain.PlainLoginModule required   
> username=“asdasdasd”   
> password=“asdasdasdasd”;  
> confluent\_cloud\_target.replication.factor = 3  
> confluent\_cloud\_target.ssl.endpoint.identification.algorithm = https  
> confluent\_cloud\_target.client.dns.lookup = use\_all\_dns\_ips
> 
> # MirrorMaker 2 Configuration for replication from source to target
> 
> confluent\_cloud\_source-\>confluent\_cloud\_target.enabled = true  
> confluent\_cloud\_source-\>confluent\_cloud\_target.topics = .\*  
> confluent\_cloud\_source-\>confluent\_cloud\_target.topics.exclude = topic-to-exclude-.\*
> 
> # Heartbeat Connector (to monitor active replication)
> 
> confluent\_cloud\_source-\>confluent\_cloud\_target.emit.heartbeats.enabled = true  
> confluent\_cloud\_source-\>confluent\_cloud\_target.heartbeats.topic = heartbeats
> 
> # Checkpoint Connector (to track offsets)
> 
> confluent\_cloud\_source-\>confluent\_cloud\_target.emit.checkpoints.enabled = true  
> confluent\_cloud\_source-\>confluent\_cloud\_target.checkpoints.topic = checkpoints
> 
> # Replication Policy
> 
> replication.policy.class = org.apache.kafka.connect.mirror.DefaultReplicationPolicy

Any clues will be highly appreciated, thanks!