Package org.apache.kafka.connect.mirror
Class MirrorClientConfig
java.lang.Object
org.apache.kafka.common.config.AbstractConfig
org.apache.kafka.connect.mirror.MirrorClientConfig
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
Modifier and TypeFieldDescriptionstatic final String
static final String
static final String
static final Class<?>
static final String
static final String
static final Boolean
static final String
static final String
static final String
static final Class<?>
static final String
static final String
Fields inherited from class org.apache.kafka.common.config.AbstractConfig
CONFIG_PROVIDERS_CONFIG
-
Method Summary
Modifier and TypeMethodDescriptionSub-config for Admin clients.Sub-config for Consumer clients.Sub-config for Producer clients.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
-
Field Details
-
REPLICATION_POLICY_CLASS
- See Also:
-
REPLICATION_POLICY_CLASS_DEFAULT
-
REPLICATION_POLICY_SEPARATOR
- See Also:
-
REPLICATION_POLICY_SEPARATOR_DEFAULT
- See Also:
-
INTERNAL_TOPIC_SEPARATOR_ENABLED
- See Also:
-
INTERNAL_TOPIC_SEPARATOR_ENABLED_DOC
- See Also:
-
INTERNAL_TOPIC_SEPARATOR_ENABLED_DEFAULT
-
FORWARDING_ADMIN_CLASS
- See Also:
-
FORWARDING_ADMIN_CLASS_DOC
- See Also:
-
FORWARDING_ADMIN_CLASS_DEFAULT
-
ADMIN_CLIENT_PREFIX
- See Also:
-
CONSUMER_CLIENT_PREFIX
- See Also:
-
PRODUCER_CLIENT_PREFIX
- See Also:
-
-
Method Details
-
replicationPolicy
-
adminConfig
Sub-config for Admin clients. -
consumerConfig
Sub-config for Consumer clients. -
producerConfig
Sub-config for Producer clients.
-