kafka在zookeeper中的元数据
所属分类 kafka
浏览量 1142
一个zk集群可以管理多个kafka集群
kafka配置文件 指定root,比如/kafka
kafka1.1.0
add the zkroot at the end of the zookeeper.connect string
zookeeper.connect=server1:2181,server2:2181/kafka
admin 管理接口操作的相关信息,主要为 topic 删除事件,分区迁移事件,优先副本选举
brokers broker 相关的信息,broker 节点以及节点上的 topic 信息
cluster 集群信息
config 动态配置信息
consumers 消费者相关信息 ( 一般为空)
controller 控制节点信息 (临时节点,用于 controller 节点注册选举)
controller_epoch controller 节点当前的年龄
isr_change_notification isr 变更通知 ( isr 变动时,用于事件通知,用 watch 获取集群 isr 变更)
latest_producer_id_block 处理事务相关的 pid 范围
log_dir_event_notification 日志目录事件通知
/kafka/cluster/id
{"version":"1","id":"ycyn9E13Qs-AkEbwN0euaA"}
/kafka/controller
{"version":1,"brokerid":1,"timestamp":"1597727176890"}
/kafka/admin/delete_topics
/brokers/ids
/brokers/topics
/brokers/ids/1
/brokers/topics/__consumer_offsets
/topics/__consumer_offsets/partitions
/brokers/topics/__consumer_offsets/partitions/1/state
ls /kafka/config
[brokers, changes, clients, topics, users]
如不设置动态参数,相关目录一般为空
0.9版本后offest不在zk上,由kafka内部topic 维护 __consumer_offsets
/kafka/brokers/ids/0
{"listener_security_protocol_map":{"PLAINTEXT":"PLAINTEXT"},"endpoints":["PLAINTEXT://localhost:9092"],"jmx_port":9995,"host":"localhost","timestamp":"1597727177018","port":9092,"version":4}
/kafka/brokers/topics/kafka_demo_test_topic
{"version":1,"partitions":{"4":[0,1],"5":[1,2],"1":[0,2],"0":[2,1],"2":[1,0],"3":[2,0]}}
/kafka/brokers/topics/kafka_demo_test_topic/partitions/0/state
{"controller_epoch":5,"leader":2,"version":1,"leader_epoch":3,"isr":[1,2]}
kafka消费者offset记录位置和方式
kafka运维常用命令
上一篇
下一篇
zookeeper四字命令conf结果说明
Zookeeper四字命令
降级 限流 熔断 简单理解
Kafka配置参数
kafka集群搭建
kafka命令行发送接收消息