Class ReplicationConfig

java.lang.Object

org.apache.kafka.common.config.AbstractConfig

io.confluent.kafka.replication.push.ReplicationConfig

public final class ReplicationConfig
extends org.apache.kafka.common.config.AbstractConfig

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static enum	ReplicationConfig.Mode	Enumerates the valid values for the REPLICATION_MODE_PROP config property.

Field Summary

Fields

Modifier and Type	Field	Description
static final String	CONFLUENT_REPLICATION_PREFIX
static final String	CONFLUENT_REPLICATION_PREFIX_NON_CCLOUD
static final boolean	INTELLIGENT_REPLICATION_FEATURE_ENABLE_DEFAULT
static final String	INTELLIGENT_REPLICATION_FEATURE_ENABLE_DOC
static final String	INTELLIGENT_REPLICATION_FEATURE_ENABLE_PROP
static final boolean	INTERNAL_TOPICS_PUSH_REPLICATION_ENABLE_DEFAULT
static final String	INTERNAL_TOPICS_PUSH_REPLICATION_ENABLE_DOC
static final String	INTERNAL_TOPICS_PUSH_REPLICATION_ENABLE_PROP
static final int	LINGER_MS_DEFAULT
static final String	LINGER_MS_DOC
static final String	LINGER_MS_PROP
static final String	LINGER_MS_PROP_NON_CCLOUD
static final int	MAX_IN_FLIGHT_REQUESTS_DEFAULT
static final String	MAX_IN_FLIGHT_REQUESTS_DOC
static final String	MAX_IN_FLIGHT_REQUESTS_PROP
static final String	MAX_IN_FLIGHT_REQUESTS_PROP_NON_CCLOUD
static final long	MAX_MEMORY_BUFFER_BYTES_DEFAULT
static final String	MAX_MEMORY_BUFFER_BYTES_DOC
static final String	MAX_MEMORY_BUFFER_BYTES_DOC_NON_CCLOUD
static final String	MAX_MEMORY_BUFFER_BYTES_PROP
static final String	MAX_MEMORY_BUFFER_BYTES_PROP_NON_CCLOUD
static final int	MAX_PUSHERS_DEFAULT
static final String	MAX_PUSHERS_DOC
static final String	MAX_PUSHERS_DOC_NON_CCLOUD
static final String	MAX_PUSHERS_PROP
static final String	MAX_PUSHERS_PROP_NON_CCLOUD
static final long	MAX_REQUEST_PARTITION_SIZE_BYTES_DEFAULT
static final String	MAX_REQUEST_PARTITION_SIZE_BYTES_DOC
static final String	MAX_REQUEST_PARTITION_SIZE_BYTES_PROP
static final String	MAX_REQUEST_PARTITION_SIZE_BYTES_PROP_NON_CCLOUD
static final long	MAX_REQUEST_SIZE_BYTES_DEFAULT
static final String	MAX_REQUEST_SIZE_BYTES_DOC
static final String	MAX_REQUEST_SIZE_BYTES_PROP
static final String	MAX_REQUEST_SIZE_BYTES_PROP_NON_CCLOUD
static final int	MAX_WAIT_MS_DEFAULT
static final String	MAX_WAIT_MS_DOC
static final String	MAX_WAIT_MS_PROP
static final String	MAX_WAIT_MS_PROP_NON_CCLOUD
static final int	NUM_PUSHERS_PER_BROKER_DEFAULT
static final String	NUM_PUSHERS_PER_BROKER_DOC
static final String	NUM_PUSHERS_PER_BROKER_PROP
static final String	NUM_PUSHERS_PER_REMOTE_BROKER_DOC_NON_CCLOUD
static final String	NUM_PUSHERS_PER_REMOTE_BROKER_PROP_NON_CCLOUD
static final boolean	PUSH_REPLICATION_FEATURE_ENABLE_DEFAULT
static final String	PUSH_REPLICATION_FEATURE_ENABLE_DOC
static final String	PUSH_REPLICATION_FEATURE_ENABLE_PROP
static final String	REPLICATION_MODE_DEFAULT
static final String	REPLICATION_MODE_DOC
static final String	REPLICATION_MODE_PROP
static final int	REQUEST_TIMEOUT_MS_DEFAULT
static final String	REQUEST_TIMEOUT_MS_PROP
static final String	REQUEST_TIMEOUT_MS_PROP_NON_CCLOUD
static final int	RETRY_TIMEOUT_MS_DEFAULT
static final String	RETRY_TIMEOUT_MS_DOC
static final String	RETRY_TIMEOUT_MS_PROP
static final String	RETRY_TIMEOUT_MS_PROP_NON_CCLOUD
static final int	SOCKET_SEND_BUFFER_BYTES_DEFAULT
static final String	SOCKET_SEND_BUFFER_BYTES_DOC
static final String	SOCKET_SEND_BUFFER_BYTES_PROP
static final String	SOCKET_SEND_BUFFER_BYTES_PROP_NON_CCLOUD

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

AUTOMATIC_CONFIG_PROVIDERS_PROPERTY, CONFIG_PROVIDERS_CONFIG

Constructor Summary

Constructors

Constructor	Description
ReplicationConfig(Map<?,?> properties, boolean isCCloud)

Method Summary

Modifier and Type	Method	Description
boolean	enablePushForInternalTopics()
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()

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

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

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, toString, wait, wait, wait

Field Details

CONFLUENT_REPLICATION_PREFIX

public static final String CONFLUENT_REPLICATION_PREFIX

See Also:

• Constant Field Values

PUSH_REPLICATION_FEATURE_ENABLE_PROP

public static final String PUSH_REPLICATION_FEATURE_ENABLE_PROP

See Also:

• Constant Field Values

PUSH_REPLICATION_FEATURE_ENABLE_DOC

public static final String PUSH_REPLICATION_FEATURE_ENABLE_DOC

See Also:

• Constant Field Values

PUSH_REPLICATION_FEATURE_ENABLE_DEFAULT

public static final boolean PUSH_REPLICATION_FEATURE_ENABLE_DEFAULT

See Also:

• Constant Field Values

REPLICATION_MODE_PROP

public static final String REPLICATION_MODE_PROP

See Also:

• Constant Field Values

REPLICATION_MODE_DOC

public static final String REPLICATION_MODE_DOC

See Also:

• Constant Field Values

REPLICATION_MODE_DEFAULT

public static final String REPLICATION_MODE_DEFAULT

MAX_PUSHERS_PROP

public static final String MAX_PUSHERS_PROP

See Also:

• Constant Field Values

MAX_PUSHERS_DOC

public static final String MAX_PUSHERS_DOC

See Also:

• Constant Field Values

MAX_PUSHERS_DEFAULT

public static final int MAX_PUSHERS_DEFAULT

See Also:

• Constant Field Values

NUM_PUSHERS_PER_BROKER_PROP

public static final String NUM_PUSHERS_PER_BROKER_PROP

See Also:

• Constant Field Values

NUM_PUSHERS_PER_BROKER_DOC

public static final String NUM_PUSHERS_PER_BROKER_DOC

See Also:

• Constant Field Values

NUM_PUSHERS_PER_BROKER_DEFAULT

public static final int NUM_PUSHERS_PER_BROKER_DEFAULT

See Also:

• Constant Field Values

MAX_MEMORY_BUFFER_BYTES_PROP

public static final String MAX_MEMORY_BUFFER_BYTES_PROP

See Also:

• Constant Field Values

MAX_MEMORY_BUFFER_BYTES_DOC

public static final String MAX_MEMORY_BUFFER_BYTES_DOC

See Also:

• Constant Field Values

MAX_MEMORY_BUFFER_BYTES_DEFAULT

public static final long MAX_MEMORY_BUFFER_BYTES_DEFAULT

See Also:

• Constant Field Values

MAX_IN_FLIGHT_REQUESTS_PROP

public static final String MAX_IN_FLIGHT_REQUESTS_PROP

See Also:

• Constant Field Values

MAX_IN_FLIGHT_REQUESTS_DOC

public static final String MAX_IN_FLIGHT_REQUESTS_DOC

See Also:

• Constant Field Values

MAX_IN_FLIGHT_REQUESTS_DEFAULT

public static final int MAX_IN_FLIGHT_REQUESTS_DEFAULT

See Also:

• Constant Field Values

MAX_REQUEST_SIZE_BYTES_PROP

public static final String MAX_REQUEST_SIZE_BYTES_PROP

See Also:

• Constant Field Values

MAX_REQUEST_SIZE_BYTES_DOC

public static final String MAX_REQUEST_SIZE_BYTES_DOC

See Also:

• Constant Field Values

MAX_REQUEST_SIZE_BYTES_DEFAULT

public static final long MAX_REQUEST_SIZE_BYTES_DEFAULT

See Also:

• Constant Field Values

MAX_REQUEST_PARTITION_SIZE_BYTES_PROP

public static final String MAX_REQUEST_PARTITION_SIZE_BYTES_PROP

See Also:

• Constant Field Values

MAX_REQUEST_PARTITION_SIZE_BYTES_DOC

public static final String MAX_REQUEST_PARTITION_SIZE_BYTES_DOC

See Also:

• Constant Field Values

MAX_REQUEST_PARTITION_SIZE_BYTES_DEFAULT

public static final long MAX_REQUEST_PARTITION_SIZE_BYTES_DEFAULT

See Also:

• Constant Field Values

LINGER_MS_PROP

public static final String LINGER_MS_PROP

See Also:

• Constant Field Values

LINGER_MS_DOC

public static final String LINGER_MS_DOC

See Also:

• Constant Field Values

LINGER_MS_DEFAULT

public static final int LINGER_MS_DEFAULT

See Also:

• Constant Field Values

MAX_WAIT_MS_PROP

public static final String MAX_WAIT_MS_PROP

See Also:

• Constant Field Values

MAX_WAIT_MS_DOC

public static final String MAX_WAIT_MS_DOC

See Also:

• Constant Field Values

MAX_WAIT_MS_DEFAULT

public static final int MAX_WAIT_MS_DEFAULT

See Also:

• Constant Field Values

RETRY_TIMEOUT_MS_PROP

public static final String RETRY_TIMEOUT_MS_PROP

See Also:

• Constant Field Values

RETRY_TIMEOUT_MS_DOC

public static final String RETRY_TIMEOUT_MS_DOC

See Also:

• Constant Field Values

RETRY_TIMEOUT_MS_DEFAULT

public static final int RETRY_TIMEOUT_MS_DEFAULT

See Also:

• Constant Field Values

REQUEST_TIMEOUT_MS_PROP

public static final String REQUEST_TIMEOUT_MS_PROP

See Also:

• Constant Field Values

REQUEST_TIMEOUT_MS_DEFAULT

public static final int REQUEST_TIMEOUT_MS_DEFAULT

See Also:

• Constant Field Values

SOCKET_SEND_BUFFER_BYTES_PROP

public static final String SOCKET_SEND_BUFFER_BYTES_PROP

See Also:

• Constant Field Values

SOCKET_SEND_BUFFER_BYTES_DEFAULT

public static final int SOCKET_SEND_BUFFER_BYTES_DEFAULT

See Also:

• Constant Field Values

SOCKET_SEND_BUFFER_BYTES_DOC

public static final String SOCKET_SEND_BUFFER_BYTES_DOC

See Also:

• Constant Field Values

INTERNAL_TOPICS_PUSH_REPLICATION_ENABLE_PROP

public static final String INTERNAL_TOPICS_PUSH_REPLICATION_ENABLE_PROP

See Also:

• Constant Field Values

INTERNAL_TOPICS_PUSH_REPLICATION_ENABLE_DEFAULT

public static final boolean INTERNAL_TOPICS_PUSH_REPLICATION_ENABLE_DEFAULT

See Also:

• Constant Field Values

INTERNAL_TOPICS_PUSH_REPLICATION_ENABLE_DOC

public static final String INTERNAL_TOPICS_PUSH_REPLICATION_ENABLE_DOC

See Also:

• Constant Field Values

CONFLUENT_REPLICATION_PREFIX_NON_CCLOUD

public static final String CONFLUENT_REPLICATION_PREFIX_NON_CCLOUD

See Also:

• Constant Field Values

INTELLIGENT_REPLICATION_FEATURE_ENABLE_PROP

public static final String INTELLIGENT_REPLICATION_FEATURE_ENABLE_PROP

See Also:

• Constant Field Values

INTELLIGENT_REPLICATION_FEATURE_ENABLE_DOC

public static final String INTELLIGENT_REPLICATION_FEATURE_ENABLE_DOC

See Also:

• Constant Field Values

INTELLIGENT_REPLICATION_FEATURE_ENABLE_DEFAULT

public static final boolean INTELLIGENT_REPLICATION_FEATURE_ENABLE_DEFAULT

See Also:

• Constant Field Values

MAX_PUSHERS_PROP_NON_CCLOUD

public static final String MAX_PUSHERS_PROP_NON_CCLOUD

See Also:

• Constant Field Values

MAX_PUSHERS_DOC_NON_CCLOUD

public static final String MAX_PUSHERS_DOC_NON_CCLOUD

See Also:

• Constant Field Values

NUM_PUSHERS_PER_REMOTE_BROKER_PROP_NON_CCLOUD

public static final String NUM_PUSHERS_PER_REMOTE_BROKER_PROP_NON_CCLOUD

See Also:

• Constant Field Values

NUM_PUSHERS_PER_REMOTE_BROKER_DOC_NON_CCLOUD

public static final String NUM_PUSHERS_PER_REMOTE_BROKER_DOC_NON_CCLOUD

See Also:

• Constant Field Values

MAX_MEMORY_BUFFER_BYTES_PROP_NON_CCLOUD

public static final String MAX_MEMORY_BUFFER_BYTES_PROP_NON_CCLOUD

See Also:

• Constant Field Values

MAX_MEMORY_BUFFER_BYTES_DOC_NON_CCLOUD

public static final String MAX_MEMORY_BUFFER_BYTES_DOC_NON_CCLOUD

See Also:

• Constant Field Values

MAX_IN_FLIGHT_REQUESTS_PROP_NON_CCLOUD

public static final String MAX_IN_FLIGHT_REQUESTS_PROP_NON_CCLOUD

See Also:

• Constant Field Values

MAX_REQUEST_SIZE_BYTES_PROP_NON_CCLOUD

public static final String MAX_REQUEST_SIZE_BYTES_PROP_NON_CCLOUD

See Also:

• Constant Field Values

MAX_REQUEST_PARTITION_SIZE_BYTES_PROP_NON_CCLOUD

public static final String MAX_REQUEST_PARTITION_SIZE_BYTES_PROP_NON_CCLOUD

See Also:

• Constant Field Values

LINGER_MS_PROP_NON_CCLOUD

public static final String LINGER_MS_PROP_NON_CCLOUD

See Also:

• Constant Field Values

MAX_WAIT_MS_PROP_NON_CCLOUD

public static final String MAX_WAIT_MS_PROP_NON_CCLOUD

See Also:

• Constant Field Values

RETRY_TIMEOUT_MS_PROP_NON_CCLOUD

public static final String RETRY_TIMEOUT_MS_PROP_NON_CCLOUD

See Also:

• Constant Field Values

REQUEST_TIMEOUT_MS_PROP_NON_CCLOUD

public static final String REQUEST_TIMEOUT_MS_PROP_NON_CCLOUD

See Also:

• Constant Field Values

SOCKET_SEND_BUFFER_BYTES_PROP_NON_CCLOUD

public static final String SOCKET_SEND_BUFFER_BYTES_PROP_NON_CCLOUD

See Also:

• Constant Field Values

Constructor Details

ReplicationConfig

public ReplicationConfig(Map<?,?> properties,
 boolean isCCloud)

Method Details

pushReplicationModeEnabled

public static boolean pushReplicationModeEnabled(ReplicationConfig.Mode configuredMode)

replicationMode

public ReplicationConfig.Mode replicationMode()

maxPushers

public int maxPushers()

maxMemoryBufferBytes

public long maxMemoryBufferBytes()

maxInFlightRequests

public int maxInFlightRequests()

maxRequestSizeBytes

public long maxRequestSizeBytes()

maxRequestPartitionSizeBytes

public long maxRequestPartitionSizeBytes()

lingerMs

public int lingerMs()

maxWaitMs

public int maxWaitMs()

retryTimeoutMs

public int retryTimeoutMs()

requestTimeoutMs

public int requestTimeoutMs()

socketSendBufferBytes

public int socketSendBufferBytes()

numPushersPerBroker

public int numPushersPerBroker()

enablePushForInternalTopics

public boolean enablePushForInternalTopics()