jsancio commented on a change in pull request #9756:
URL: https://github.com/apache/kafka/pull/9756#discussion_r555470725
##########
File path: raft/src/main/java/org/apache/kafka/raft/RaftConfig.java
##########
@@ -59,6 +60,11 @@
private static final String QUORUM_LINGER_MS_DOC = "The duration in
milliseconds that the leader will " +
"wait for writes to accumulate before flushing them to disk.";
+ public static final String QUORUM_FLUSH_MIN_SIZE_BYTES_CONFIG =
QUORUM_PREFIX + "flush.minSize.bytes";
Review comment:
I like the suggestion of using `quorum.append.max.unflushed.bytes`. I
would mention in the documentation that this is a best effort. Based on how
`KafakRaftClient` calls drain, it is possible for accumulator have more
unflushed bytes.
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
us...@infra.apache.org
