Class MirrorClientConfig

java.lang.Object
org.apache.kafka.common.config.AbstractConfig
org.apache.kafka.connect.mirror.MirrorClientConfig

public class MirrorClientConfig extends AbstractConfig
Configuration required for MirrorClient to talk to a given target cluster.

Generally, these properties come from an mm2.properties configuration file (@see MirrorMakerConfig.clientConfig):

    MirrorMakerConfig mmConfig = new MirrorMakerConfig(props);
    MirrorClientConfig mmClientConfig = mmConfig.clientConfig("some-cluster");
  

In addition to the properties defined here, sub-configs are supported for Admin, Consumer, and Producer clients. For example:

      bootstrap.servers = host1:9092
      consumer.client.id = mm2-client
      replication.policy.separator = __
  
  • Field Details

  • Method Details

    • replicationPolicy

      public ReplicationPolicy replicationPolicy()
    • adminConfig

      public Map<String,Object> adminConfig()
      Sub-config for Admin clients.
    • consumerConfig

      public Map<String,Object> consumerConfig()
      Sub-config for Consumer clients.
    • producerConfig

      public Map<String,Object> producerConfig()
      Sub-config for Producer clients.