← 返回首页

Kafka 的文件存储机制是怎样的?

分段存储:Topic 的 Partition 被分成多个 Segment(段),每个段包含一个 .log (数据)、.index (偏移量索引)、.timeindex (时间索引)。

稀疏索引:Index 文件不是每条消息都存,而是每隔几条存一次(稀疏),查找时先二分查找 Index,再定位到 Log 文件的具体位置扫描。

删除策略:

基于时间:超过保留时间(如 7 天)删除。

基于大小:超过磁盘配额删除。

删除旧 Segment 文件,而不是逐条删除消息(效率高)。