3 Matching Annotations
  1. Apr 2025
    1. (validBytes - lastIndexEntry > indexIntervalBytes)

      recover过程中会重置索引,然后遍历每个batch来添加索引项,这样就能避免掉原本写入消息时,一次性写入的多batch的消息最多只写入一次索引导致查询效率低的问题

    2. recover 方法

      什么时候recover?

      kafka在shutdown的时候会将segment刷盘并维护checkpoint和.kafka_cleanshutdown文件,每个partition一份.重启的时候会进行判定

  2. Jan 2018