Class RemoteClusterUtils

java.lang.Object
org.apache.kafka.connect.mirror.RemoteClusterUtils

public final class RemoteClusterUtils extends Object
Convenience methods for multi-cluster environments. Wraps MirrorClient (@see MirrorClient).

Properties passed to these methods are used to construct internal Admin and Consumer clients. Sub-configs like "admin.xyz" are also supported. For example:

      bootstrap.servers = host1:9092
      consumer.client.id = mm2-client
  

See Also: