← 返回首页
Kafka 的文件存储机制是怎样的?
分段存储:Topic 的 Partition 被分成多个 Segment(段),每个段包含一个 .log (数据)、.index (偏移量索引)、.timeindex (时间索引)。
稀疏索引:Index 文件不是每条消息都存,而是每隔几条存一次(稀疏),查找时先二分查找 Index,再定位到 Log 文件的具体位置扫描。
删除策略:
基于时间:超过保留时间(如 7 天)删除。
基于大小:超过磁盘配额删除。
删除旧 Segment 文件,而不是逐条删除消息(效率高)。