Set<String> listTopics() throws InterruptedException {
        try {
            return adminClient.listTopics().names().get();
        } catch (ExecutionException e) {
            throw new KafkaException(e.getCause());
        }
    }
Translates a remote consumer group's offsets into corresponding local offsets. Topics are automatically
renamed according to the ReplicationPolicy.
@param consumerGroupId The group ID of remote consumer group
@param remoteClusterAlias The alias of remote cluster
@param timeout The maximum time to block when consuming from the checkpoints topic
connect/mirror-client/src/main/java/org/apache/kafka/connect/mirror/MirrorClient.java