Class IdentityReplicationPolicy

java.lang.Object
org.apache.kafka.connect.mirror.DefaultReplicationPolicy
org.apache.kafka.connect.mirror.IdentityReplicationPolicy
All Implemented Interfaces:
Configurable, ReplicationPolicy

public class IdentityReplicationPolicy extends DefaultReplicationPolicy
IdentityReplicationPolicy does not rename remote topics. This is useful for migrating from legacy MM1, or for any use-case involving one-way replication.

N.B. MirrorMaker is not able to prevent cycles when using this class, so take care that your replication topology is acyclic. If migrating from MirrorMaker v1, this will likely already be the case.