class MirrorClient implements AutoCloseable {

    int countHopsForTopic(String topic, String sourceClusterAlias) {
        int hops = 0;
        while (true) {
            hops++;
            String source = replicationPolicy.topicSource(topic);
            if (source == null) {
                return -1;
            }
            if (source.equals(sourceClusterAlias)) {
                return hops;
            }
            topic = replicationPolicy.upstreamTopic(topic);
        } 
    }

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

}