"confluent.replication."
"confluent.intelligent.replication."
public static final boolean
false
"Feature flag that enables components related to the intelligent replication feature for improved replication performance. As a requirement, the metadata version must be at least `4_1_IV1` before this feature can be enabled. This feature can be disabled dynamically at runtime, but dynamically re-enabling is not supported."
"confluent.intelligent.replication.enable"
public static final boolean
false
"Whether internal topics are allowed to transition to push mode"
"confluent.replication.push.internal.topics.enable"
public static final int
0
"The amount of time to wait before attempting to send a replication request containing record data to a follower broker."
"confluent.replication.linger.ms"
"confluent.intelligent.replication.push.linger.ms"
public static final int
1
"The maximum number of replication requests that can be simultaneously in-flight."
"confluent.replication.max.in.flight.requests"
"confluent.intelligent.replication.push.max.in.flight.requests"
public static final long
209715200L
"The maximum amount of memory used by replication for buffering. Currently used solely by the records buffer for push replication."
"The maximum amount of memory used by push replication for buffering. Currently used solely by the records buffer for intelligent replication."
"confluent.replication.max.memory.buffer.bytes"
"confluent.intelligent.replication.push.max.memory.buffer.bytes"
public static final int
4
"The maximum number of pusher threads to be used for push replication."
"The maximum number of pusher threads to be used for push replication."
"confluent.replication.max.replica.pushers"
"confluent.intelligent.replication.push.max.threads"
public static final long
52428800L
"The maximum size in bytes for the data of a single partition in a replication request."
"confluent.replication.request.max.partition.bytes"
"confluent.intelligent.replication.push.request.max.partition.bytes"
public static final long
52428800L
"The maximum size in bytes of a replication request, similar to the \'fetch.max.bytes\' for Fetch requests."
"confluent.replication.request.max.bytes"
"confluent.intelligent.replication.push.request.max.bytes"
public static final int
500
"The amount of time to wait before attempting to send a replication request containing only offset metadata to a follower broker."
"confluent.replication.max.wait.ms"
"confluent.intelligent.replication.push.metadata.max.wait.ms"
public static final int
1
"Determines the number of pushers replicating to a single peer broker. Can be between 1 and the maximum number of pusher threads."
"confluent.replication.num.pushers.per.broker"
"Determines the number of pushers replicating to a single peer broker. Can be between 1 and the maximum number of pusher threads."
"confluent.intelligent.replication.push.threads.per.remote.broker"
public static final boolean
false
"Feature flag that enables components related to the push replication feature for improved replication performance. This must be enabled before push replication mode can be enabled by using `confluent.replication.mode` property.As a requirement, the metadata version must be at least `4_1_IV1` before this feature can be enabled."
"confluent.replication.push.feature.enable"
"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.The `confluent.replication.push.feature.enable` property must be enabled before push replication mode can be enabled.As a requirement, the metadata version must be at least `4_1_IV1` before this feature can be enabled."
"confluent.replication.mode"
public static final int
5000
"confluent.replication.request.timeout.ms"
"confluent.intelligent.replication.push.request.timeout.ms"
public static final int
10000
"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."
"confluent.replication.retry.timeout.ms"
"confluent.intelligent.replication.push.retry.timeout.ms"
public static final int
1048576
"The socket send buffer for network requests to the follower for replicating data"
"confluent.replication.socket.send.buffer.bytes"
"confluent.intelligent.replication.push.socket.buffer.bytes"
public static final boolean
false
"Flag that enables or disables the controller from exempting sticky healthcheck topics from being moved away during demotion/degradation of a broker."
"confluent.replication.sticky.topic.exemption.enable"