public Set<String> remoteTopics() throws InterruptedException {
        return listTopics().stream()
            .filter(this::isRemoteTopic)
            .collect(Collectors.toSet());
    }
Finds all remote topics on this cluster. This does not include internal topics (heartbeats, checkpoints).
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClient.java