(validBytes - lastIndexEntry > indexIntervalBytes)
recover过程中会重置索引，然后遍历每个batch来添加索引项，这样就能避免掉原本写入消息时，一次性写入的多batch的消息最多只写入一次索引导致查询效率低的问题
3 Matching Annotations
- Apr 2025
-
book.originit.top book.originit.top
-
-
recover 方法
什么时候recover？
kafka在shutdown的时候会将segment刷盘并维护checkpoint和.kafka_cleanshutdown文件，每个partition一份.重启的时候会进行判定
-
- Jan 2018
-
engineering.linkedin.com engineering.linkedin.com
-
The Log: What every software engineer should know about real-time data's unifying abstraction
-