首先 我们先了解一下kafka在zookeeper上的文件结构,进入一台zookeeper主机,输入命令 bin/zkCli.sh 进入交互模式,ls出zk的根目录,如下图
这篇文章我们分析一下上图中除了zookeeper的其他文件夹对于kafka来说都是什么含义。
zk-root根目录包含6个kafka主文件夹目录,分别为consumers(消费者信息),config(Kafka配置信息),
,brokers(brokers的信息,包括topic信息和ID信息等),admin(一些常用的管理信息,例如删除等),contorller_epoch(存储kafka集群的中央控制器选举的次数)。
下面夏天小厨详细的介绍一下以上文件夹对应的子文件夹:
ids(消费者的ID) 1、consumers(消费者信息)====> consumer group (消费者组) ====> owners(消费者所在的主机信息) myKafKaDemo1(具体的topic) topics(KafKa的topic信息) =======>myKafKaDemo1 2、config(kafka配置信息)===> testTopic changes(配置信息修改的日志文件) 3、controller(存储中央控制的BrokerID等信息)一般无子文件夹 myKafKaDemo1==>partitons(分区信息) topics(Broker上的topic信息)====>(具体创建的topic信息) 4、brokers(brokers ====> myKafKaDemo2==>partitions 的信息,包括topic ids(broker的ID信息)======> 0 (具体的brokerID) 信息和ID信息等) 1 5、admin(一些管理信息)=====>delete_topics(删除的topic信息) 6、contorller_epoch(存储kafka集群的中央控制器选举的次数)其文件存储结构图如下图所示:
