kafka工作流程分析-Broker保存消息

存储方式 物理上把 topic 分成一个或多个 patition（对应 server.properties 中的 num.partitions=3 配置），每个 patition 物理上对应一个文件夹（该文件夹存储该 patition 的所有消息和索引文件），如下： 存储策略 无论消息是否被消费，kafka 都会保留所有消息。有两种策略可以删除旧数据： 1）基于时间：log.retention.h

>>阅读原文<<