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	FORWARDING_ADMIN_CLASS
static final Class<?>	FORWARDING_ADMIN_CLASS_DEFAULT
static final String	FORWARDING_ADMIN_CLASS_DOC
static final String	INTERNAL_TOPIC_SEPARATOR_ENABLED
static final Boolean	INTERNAL_TOPIC_SEPARATOR_ENABLED_DEFAULT
static final String	INTERNAL_TOPIC_SEPARATOR_ENABLED_DOC
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

INTERNAL_TOPIC_SEPARATOR_ENABLED

public static final String INTERNAL_TOPIC_SEPARATOR_ENABLED

See Also:

• Constant Field Values

INTERNAL_TOPIC_SEPARATOR_ENABLED_DOC

public static final String INTERNAL_TOPIC_SEPARATOR_ENABLED_DOC

See Also:

• Constant Field Values

INTERNAL_TOPIC_SEPARATOR_ENABLED_DEFAULT

public static final Boolean INTERNAL_TOPIC_SEPARATOR_ENABLED_DEFAULT

FORWARDING_ADMIN_CLASS

public static final String FORWARDING_ADMIN_CLASS

See Also:

• Constant Field Values

FORWARDING_ADMIN_CLASS_DOC

public static final String FORWARDING_ADMIN_CLASS_DOC

See Also:

• Constant Field Values

FORWARDING_ADMIN_CLASS_DEFAULT

public static final Class<?> FORWARDING_ADMIN_CLASS_DEFAULT

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.