root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 2 Packages Projects Releases Wiki Activity

KAFKA-19151 docs: clarify that flush.ms requires log.flush.scheduler.interval.ms config (#19479) 

Enhanced docs of `flush.ms` to remind users the flush is triggered by
`log.flush.scheduler.interval.ms`.

Reviewers: PoAn Yang <payang@apache.org>, Ken Huang
<s7133700@gmail.com>, TengYao Chi <kitingiao@gmail.com>, Chia-Ping Tsai
<chia7712@gmail.com>
This commit is contained in:
yunchi 2025-04-16 20:19:44 -07:00 committed by GitHub
parent b4e75fbab1
commit effbad9e80
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
clients/src/main/java/org/apache/kafka/common/config/TopicConfig.java
View File

@ -58,9 +58,10 @@ public class TopicConfig {
public static final String FLUSH_MS_CONFIG = "flush.ms";
public static final String FLUSH_MS_DOC = "This setting allows specifying a time interval at which we will " +
"force an fsync of data written to the log. For example if this was set to 1000 " +
"we would fsync after 1000 ms had passed. In general we recommend you not set " +
"this and use replication for durability and allow the operating system's background " +
"flush capabilities as it is more efficient.";
"we would fsync after 1000 ms had passed. Note that this setting depends on the broker-level " +
"configuration <code>log.flush.scheduler.interval.ms</code>, which controls how frequently the flush check occurs. " +
"In general we recommend you not set this and use replication for durability and allow the operating system's " +
"background flush capabilities as it is more efficient.";
public static final String RETENTION_BYTES_CONFIG = "retention.bytes";
public static final String RETENTION_BYTES_DOC = "This configuration controls the maximum size a partition " +