@Override
    public boolean isMM2InternalTopic(String topic) {
        return super.isMM2InternalTopic(topic) || isHeartbeatsTopic(topic) || isCheckpointsTopic(topic);
    }
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