@Override
    public void configure(Map<String, ?> props) {
        super.configure(props);
        if (props.containsKey(SOURCE_CLUSTER_ALIAS_CONFIG)) {
            sourceClusterAlias = (String) props.get(SOURCE_CLUSTER_ALIAS_CONFIG);
            log.info("Using source cluster alias `{}`.", sourceClusterAlias);
        }
    }
Alternative implementation of {@link ReplicationPolicy} that does not rename remote topics.
This is useful for migrating from legacy MirrorMaker, or for any use-case involving one-way replication.
<p>
N.B. MirrorMaker is not able to prevent cycles when using this replication policy, so take care that
your replication topology is acyclic. If migrating from legacy MirrorMaker, this will likely already be the case.
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/IdentityReplicationPolicy.java