public static final String |
CONFLUENT_REPLICATION_PREFIX |
"confluent.replication." |
public static final boolean |
INTERNAL_TOPICS_PUSH_REPLICATION_ENABLE_DEFAULT |
false |
public static final String |
INTERNAL_TOPICS_PUSH_REPLICATION_ENABLE_DOC |
"Whether internal topics are allowed to transition to push mode" |
public static final String |
INTERNAL_TOPICS_PUSH_REPLICATION_ENABLE_PROP |
"confluent.replication.push.internal.topics.enable" |
public static final int |
LINGER_MS_DEFAULT |
0 |
public static final String |
LINGER_MS_DOC |
"The amount of time to wait before attempting to send a replication request containing record data to a follower broker." |
public static final String |
LINGER_MS_PROP |
"confluent.replication.linger.ms" |
public static final int |
MAX_IN_FLIGHT_REQUESTS_DEFAULT |
1 |
public static final String |
MAX_IN_FLIGHT_REQUESTS_DOC |
"The maximum number of replication requests that can be simultaneously in-flight." |
public static final String |
MAX_IN_FLIGHT_REQUESTS_PROP |
"confluent.replication.max.in.flight.requests" |
public static final long |
MAX_MEMORY_BUFFER_BYTES_DEFAULT |
209715200L |
public static final String |
MAX_MEMORY_BUFFER_BYTES_DOC |
"The maximum amount of memory used by replication for buffering. Currently used solely by the records buffer for push replication." |
public static final String |
MAX_MEMORY_BUFFER_BYTES_PROP |
"confluent.replication.max.memory.buffer.bytes" |
public static final int |
MAX_PUSHERS_DEFAULT |
4 |
public static final String |
MAX_PUSHERS_DOC |
"The maximum number of pusher threads to be used for push replication." |
public static final String |
MAX_PUSHERS_PROP |
"confluent.replication.max.replica.pushers" |
public static final long |
MAX_REQUEST_PARTITION_SIZE_BYTES_DEFAULT |
52428800L |
public static final String |
MAX_REQUEST_PARTITION_SIZE_BYTES_DOC |
"The maximum size in bytes for the data of a single partition in a replication request." |
public static final String |
MAX_REQUEST_PARTITION_SIZE_BYTES_PROP |
"confluent.replication.request.max.partition.bytes" |
public static final long |
MAX_REQUEST_SIZE_BYTES_DEFAULT |
52428800L |
public static final String |
MAX_REQUEST_SIZE_BYTES_DOC |
"The maximum size in bytes of a replication request, similar to the \'fetch.max.bytes\' for Fetch requests." |
public static final String |
MAX_REQUEST_SIZE_BYTES_PROP |
"confluent.replication.request.max.bytes" |
public static final int |
MAX_WAIT_MS_DEFAULT |
500 |
public static final String |
MAX_WAIT_MS_DOC |
"The amount of time to wait before attempting to send a replication request containing only offset metadata to a follower broker." |
public static final String |
MAX_WAIT_MS_PROP |
"confluent.replication.max.wait.ms" |
public static final int |
NUM_PUSHERS_PER_BROKER_DEFAULT |
1 |
public static final String |
NUM_PUSHERS_PER_BROKER_DOC |
"Determines the number of pushers replicating to a single peer broker. Can be between 1 and the maximum number of pusher threads." |
public static final String |
NUM_PUSHERS_PER_BROKER_PROP |
"confluent.replication.num.pushers.per.broker" |
public static final boolean |
PUSH_REPLICATION_FEATURE_ENABLE_DEFAULT |
false |
public static final String |
PUSH_REPLICATION_FEATURE_ENABLE_DOC |
"Feature flag that enables components related to push replication. This must be enabled before push replication mode can be enabled by using `REPLICATION_MODE_PROP` property." |
public static final String |
PUSH_REPLICATION_FEATURE_ENABLE_PROP |
"confluent.replication.push.feature.enable" |
public static final String |
REPLICATION_MODE_DOC |
"Determines the replication mode used by this broker both when acting as a leader and when acting as a follower. Can be PULL or PULL_PUSH, with PUSH to be added eventually." |
public static final String |
REPLICATION_MODE_PROP |
"confluent.replication.mode" |
public static final int |
REQUEST_TIMEOUT_MS_DEFAULT |
5000 |
public static final String |
REQUEST_TIMEOUT_MS_PROP |
"confluent.replication.request.timeout.ms" |
public static final int |
RETRY_TIMEOUT_MS_DEFAULT |
10000 |
public static final String |
RETRY_TIMEOUT_MS_DOC |
"The total timeout to wait on a leader for a response to a replication request (with retries on retriable errors not resetting the clock) before transitioning the corresponding partition replica(s) back to replication mode PULL." |
public static final String |
RETRY_TIMEOUT_MS_PROP |
"confluent.replication.retry.timeout.ms" |
public static final int |
SOCKET_SEND_BUFFER_BYTES_DEFAULT |
1048576 |
public static final String |
SOCKET_SEND_BUFFER_BYTES_DOC |
"The socket send buffer for network requests to the follower for replicating data" |
public static final String |
SOCKET_SEND_BUFFER_BYTES_PROP |
"confluent.replication.socket.send.buffer.bytes" |