網上有一種說法,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