@Override
    public String checkpointsTopic(String clusterAlias) {
        String checkpointsTopic = System.getenv(CHECKPOINTS_TOPIC_ENV_KEY);
        if (checkpointsTopic == null) {
            return super.checkpointsTopic(clusterAlias);
        }
        return checkpointsTopic;
    }
AutoMQIdentityReplicationPolicy is a custom implementation of the ReplicationPolicy interface that allows for the
configuration of the offset-syncs-topic, checkpoints-topic, and heartbeats-topic via environment variables.
<p>
See more details from KIP-690.
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/AutoMQIdentityReplicationPolicy.java