default String checkpointsTopic(String clusterAlias) {
        return clusterAlias + ".checkpoints.internal";
    }
Returns the name of the checkpoints topic for given cluster alias.
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/ReplicationPolicy.java