public ReplicationPolicy replicationPolicy() {
        return getConfiguredInstance(REPLICATION_POLICY_CLASS, ReplicationPolicy.class);
    }
Configuration required for {@link MirrorClient} to talk to a given target cluster.
<p>
  This needs to contain at least the connection details for the target cluster (<code>bootstrap.servers</code> and
  any required TLS/SASL configuration), as well as {@link #REPLICATION_POLICY_CLASS} when not using the default
  replication policy. It can also include {@link AdminClientConfig} and {@link ConsumerConfig} to customize the
  internal clients this uses. For example:
  <pre>
     bootstrap.servers = host1:9092
     consumer.client.id = mm2-client
     replication.policy.separator = __
  </pre>
</p>
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClientConfig.java