网上有一种说法,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