Class MirrorClientConfig


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

Generally, these properties come from an 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 = 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.