Package org.apache.kafka.connect.mirror

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 Summary

Fields

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

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

CONFIG_PROVIDERS_CONFIG

Method Summary

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 Details

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 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.