public final class ReplicationConfig
extends org.apache.kafka.common.config.AbstractConfig
Modifier and Type | Class and Description |
---|---|
static class |
ReplicationConfig.Mode
Enumerates the valid values for the
REPLICATION_MODE_PROP config property. |
Constructor and Description |
---|
ReplicationConfig(Map<?,?> properties) |
Modifier and Type | Method and Description |
---|---|
static org.apache.kafka.common.config.ConfigDef |
defineReplicationConfigs() |
int |
lingerMs() |
int |
maxInFlightRequests() |
long |
maxMemoryBufferBytes() |
int |
maxPushers() |
long |
maxRequestPartitionSizeBytes() |
long |
maxRequestSizeBytes() |
int |
maxWaitMs() |
int |
numPushersPerBroker() |
static boolean |
pushReplicationModeEnabled(ReplicationConfig.Mode configuredMode) |
ReplicationConfig.Mode |
replicationMode() |
int |
requestTimeoutMs() |
int |
retryTimeoutMs() |
int |
socketSendBufferBytes() |
documentationOf, equals, getBoolean, getClass, getConfiguredInstance, getConfiguredInstance, getConfiguredInstances, getConfiguredInstances, getConfiguredInstances, getDouble, getInt, getList, getLong, getPassword, getShort, getString, hashCode, ignore, logUnused, nonInternalValues, originals, originals, originalsStrings, originalsWithPrefix, originalsWithPrefix, typeOf, unused, values, valuesWithPrefixAllOrNothing, valuesWithPrefixOverride
public static final String CONFLUENT_REPLICATION_PREFIX
public static final String PUSH_REPLICATION_FEATURE_ENABLE_PROP
public static final String PUSH_REPLICATION_FEATURE_ENABLE_DOC
public static final boolean PUSH_REPLICATION_FEATURE_ENABLE_DEFAULT
public static final String REPLICATION_MODE_PROP
public static final String REPLICATION_MODE_DOC
public static final String REPLICATION_MODE_DEFAULT
public static final String MAX_PUSHERS_PROP
public static final String MAX_PUSHERS_DOC
public static final int MAX_PUSHERS_DEFAULT
public static final String NUM_PUSHERS_PER_BROKER_PROP
public static final String NUM_PUSHERS_PER_BROKER_DOC
public static final int NUM_PUSHERS_PER_BROKER_DEFAULT
public static final String MAX_MEMORY_BUFFER_BYTES_PROP
public static final String MAX_MEMORY_BUFFER_BYTES_DOC
public static final long MAX_MEMORY_BUFFER_BYTES_DEFAULT
public static final String MAX_IN_FLIGHT_REQUESTS_PROP
public static final String MAX_IN_FLIGHT_REQUESTS_DOC
public static final int MAX_IN_FLIGHT_REQUESTS_DEFAULT
public static final String MAX_REQUEST_SIZE_BYTES_PROP
public static final String MAX_REQUEST_SIZE_BYTES_DOC
public static final long MAX_REQUEST_SIZE_BYTES_DEFAULT
public static final String MAX_REQUEST_PARTITION_SIZE_BYTES_PROP
public static final String MAX_REQUEST_PARTITION_SIZE_BYTES_DOC
public static final long MAX_REQUEST_PARTITION_SIZE_BYTES_DEFAULT
public static final String LINGER_MS_PROP
public static final String LINGER_MS_DOC
public static final int LINGER_MS_DEFAULT
public static final String MAX_WAIT_MS_PROP
public static final String MAX_WAIT_MS_DOC
public static final int MAX_WAIT_MS_DEFAULT
public static final String RETRY_TIMEOUT_MS_PROP
public static final String RETRY_TIMEOUT_MS_DOC
public static final int RETRY_TIMEOUT_MS_DEFAULT
public static final String REQUEST_TIMEOUT_MS_PROP
public static final int REQUEST_TIMEOUT_MS_DEFAULT
public static final String SOCKET_SEND_BUFFER_BYTES_PROP
public static final int SOCKET_SEND_BUFFER_BYTES_DEFAULT
public static final String SOCKET_SEND_BUFFER_BYTES_DOC
public ReplicationConfig(Map<?,?> properties)
public static org.apache.kafka.common.config.ConfigDef defineReplicationConfigs()
public static boolean pushReplicationModeEnabled(ReplicationConfig.Mode configuredMode)
public ReplicationConfig.Mode replicationMode()
public int maxPushers()
public long maxMemoryBufferBytes()
public int maxInFlightRequests()
public long maxRequestSizeBytes()
public long maxRequestPartitionSizeBytes()
public int lingerMs()
public int maxWaitMs()
public int retryTimeoutMs()
public int requestTimeoutMs()
public int socketSendBufferBytes()
public int numPushersPerBroker()