[TOC] # 存储方式 物理上把topic分成一个或多个partition(对应server.properties中的num.partitions=3配置),每个partition物理上对应一个文件夹(该文件夹存储该partition的所有消息和索引文件) # 存储策略 无论消息是否被消费,kafka都会保留所有消息.有两种策略可以删除旧数据: 1. 基于时间: log.retention.hours=168 2. 基于大小: log.retention.bytes=1073741824 需要注意的是,因为kafka读取特定消息的时间复杂度为O(1),即与文件大小无关,所以这里删除过期文件与提高kafka性能无关 # zookeeper存储结构  注意: producer不在zk注册,消费者在zk中注册