public Set<String> checkpointTopics() throws InterruptedException {
        return listTopics().stream()
            .filter(this::isCheckpointTopic)
            .collect(Collectors.toSet());
    }
Finds all checkpoints topics on this cluster.
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClient.java