class MirrorClient implements AutoCloseable {

    public Set<String> heartbeatTopics() throws InterruptedException {
        return listTopics().stream()
            .filter(this::isHeartbeatTopic)
            .collect(Collectors.toSet());
    }

    public  MirrorClient(Map<String, Object> props);
    public  MirrorClient(MirrorClientConfig config);
      MirrorClient(AdminClient adminClient, ReplicationPolicy replicationPolicy,
            Map<String, Object> consumerConfig);

}