kafka文件存储机制和消费者

1.broker文件存储机制

去查看真正的存储文件：

在/opt/module/kafka/datas/ 路径下

kafka-run-class.sh kafka.tools.DumpLogSegments --files ./00000000000000000000.index

 如果是6415那么这个会存储在563的log文件之中，因为介于6410和10090之间。

2.文件清除策略

 

 日志压缩用的比较少，比如针对用户，18岁19岁，只需要保存最新的就行。

 3.高效读写数据

4.kafka消费者 

5.消费者组初始化流程