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 Summary

Fields
Modifier and Type	Field	Description
`static String`	`ADMIN_CLIENT_PREFIX`
`static String`	`CONSUMER_CLIENT_PREFIX`
`static String`	`PRODUCER_CLIENT_PREFIX`
`static String`	`REPLICATION_POLICY_CLASS`
`static Class<?>`	`REPLICATION_POLICY_CLASS_DEFAULT`
`static String`	`REPLICATION_POLICY_SEPARATOR`
`static String`	`REPLICATION_POLICY_SEPARATOR_DEFAULT`

Fields inherited from class org.apache.kafka.common.config.AbstractConfig
CONFIG_PROVIDERS_CONFIG

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type	Method	Description
`Map<String,Object>`	`adminConfig()`	Sub-config for Admin clients.
`Map<String,Object>`	`consumerConfig()`	Sub-config for Consumer clients.
`Map<String,Object>`	`producerConfig()`	Sub-config for Producer clients.
`ReplicationPolicy`	`replicationPolicy()`

Methods inherited from class org.apache.kafka.common.config.AbstractConfig
documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride

Methods inherited from class java.lang.Object
clone, finalize, getClass, notify, notifyAll, toString, wait, wait, wait

Field Detail

REPLICATION_POLICY_CLASS

public static final String REPLICATION_POLICY_CLASS

See Also:: Constant Field Values

REPLICATION_POLICY_CLASS_DEFAULT

public static final Class<?> REPLICATION_POLICY_CLASS_DEFAULT

REPLICATION_POLICY_SEPARATOR

public static final String REPLICATION_POLICY_SEPARATOR

See Also:: Constant Field Values

REPLICATION_POLICY_SEPARATOR_DEFAULT

public static final String REPLICATION_POLICY_SEPARATOR_DEFAULT

See Also:: Constant Field Values

ADMIN_CLIENT_PREFIX

public static final String ADMIN_CLIENT_PREFIX

See Also:: Constant Field Values

CONSUMER_CLIENT_PREFIX

public static final String CONSUMER_CLIENT_PREFIX

See Also:: Constant Field Values

PRODUCER_CLIENT_PREFIX

public static final String PRODUCER_CLIENT_PREFIX

See Also:: Constant Field Values

Method Detail

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.

Class MirrorClientConfig