public Set<String> remoteTopics(String source) throws InterruptedException {
        return listTopics().stream()
            .filter(this::isRemoteTopic)
            .filter(x -> source.equals(replicationPolicy.topicSource(x)))
            .collect(Collectors.toSet());
    }
Finds all remote topics that have been replicated directly from the given source cluster.
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClient.java