public ReplicationPolicy replicationPolicy() {
        return replicationPolicy;
    }
Gets the {@link ReplicationPolicy} instance used to interpret remote topics. This instance is constructed based on
relevant configuration properties, including {@code replication.policy.class}.
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClient.java