Kafka同步刷盤


網上有一種說法,kafka不支持同步刷盤,這種說法也不能說是錯的。但是還是可以通過參數的配置變成同步刷盤

log.flush.interval.messages  //多少條消息,刷盤1次 默認值 LONG.MAX_VALUE
log.flush.interval.ms  //割多長時間,刷盤1次 LONG.MAX_VALUE
 log.flush.scheduler.interval.ms //周期性的刷盤,缺省3000,即3s。

默認值

log.flush.interval.messages  在將消息刷新到磁盤之前,在日志分區上累積的消息數量
# 當達到下面的消息數量時,會將數據flush到日志文件中。默認10000
#log.flush.interval.messages=10000
# 當達到下面的時間(ms)時,執行一次強制的flush操作。interval.ms和interval.messages無論哪個達到,都會flush。默認3000ms
#log.flush.interval.ms=1000
# 檢查是否需要將日志flush的時間間隔
log.flush.scheduler.interval.ms = 3000

 


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM