public class MirrorClientConfig
extends org.apache.kafka.common.config.AbstractConfig
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 = __
Modifier and Type | Field and Description |
---|---|
static java.lang.String |
ADMIN_CLIENT_PREFIX |
static java.lang.String |
CONSUMER_CLIENT_PREFIX |
static java.lang.String |
PRODUCER_CLIENT_PREFIX |
static java.lang.String |
REPLICATION_POLICY_CLASS |
static java.lang.Class<?> |
REPLICATION_POLICY_CLASS_DEFAULT |
static java.lang.String |
REPLICATION_POLICY_SEPARATOR |
static java.lang.String |
REPLICATION_POLICY_SEPARATOR_DEFAULT |
Modifier and Type | Method and Description |
---|---|
java.util.Map<java.lang.String,java.lang.Object> |
adminConfig()
Sub-config for Admin clients.
|
java.util.Map<java.lang.String,java.lang.Object> |
consumerConfig()
Sub-config for Consumer clients.
|
java.util.Map<java.lang.String,java.lang.Object> |
producerConfig()
Sub-config for Producer clients.
|
ReplicationPolicy |
replicationPolicy() |
documentationOf, equals, get, getBoolean, getClass, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, postProcessParsedConfig, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final java.lang.String REPLICATION_POLICY_CLASS
public static final java.lang.Class<?> REPLICATION_POLICY_CLASS_DEFAULT
public static final java.lang.String REPLICATION_POLICY_SEPARATOR
public static final java.lang.String REPLICATION_POLICY_SEPARATOR_DEFAULT
public static final java.lang.String ADMIN_CLIENT_PREFIX
public static final java.lang.String CONSUMER_CLIENT_PREFIX
public static final java.lang.String PRODUCER_CLIENT_PREFIX
public ReplicationPolicy replicationPolicy()
public java.util.Map<java.lang.String,java.lang.Object> adminConfig()
public java.util.Map<java.lang.String,java.lang.Object> consumerConfig()
public java.util.Map<java.lang.String,java.lang.Object> producerConfig()