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

存儲方式 物理上把 topic 分成一個或多個 patition（對應 server.properties 中的 num.partitions=3 配置），每個 patition 物理上對應一個文件夾（該文件夾存儲該 patition 的所有消息和索引文件），如下： 存儲策略 無論消息是否被消費，kafka 都會保留所有消息。有兩種策略可以刪除舊數據： 1）基於時間：log.retention.h

>>阅读原文<<