/brokers/topics/[topic] :
儲存某個topic的partitions所有分配資訊
}
/brokers/topics/[topic]/partitions/[0…n] 其中[0…n]表示partition索引號
每個broker的配置檔案中都需要指定乙個數字型別的id(全域性不可重複),此節點為臨時znode(ephemeral)
1,// jmx埠號
"host"
:"zjj101"
,// 主機名或ip位址,
"timestamp"
:"1614570663881"
,//kafka broker初始啟動時的時間戳,
"port"
:9092
,// kafka broker的服務端埠號,由server.properties中引數port確定
"version":4
// 版本編號預設為1,
}/controller_epoch --> int (epoch)
此值為乙個數字,kafka集群中第乙個broker第一次啟動時為1,以後只要集群中center controller**控制器所在broker變更或掛掉,就會重新選舉新的center controller,每次center controller變更controller_epoch值就會 + 1;
/controller -> int (broker id of the controller) 儲存center controller**控制器所在kafka broker的資訊
Kafka在zookeeper中的資料結構
一 brokers節點 brokers brokers topics brokers topics test2 brokers topics test2 partitions brokers topics test2 partitions 0 brokers topics test2 partiti...
kafka集群安裝(獨立zookeeper集群)
1 集群環境 192.168.100.200 192.168.100.201 192.168.100.202 2 按照步驟 root localhost local tar zxvf kafka 2.11 0.10.1.0.tgz root localhost local cd kafka 2.11...
Kafka安裝之一 Zookeeper
kafka安裝之一 zookeeper kafka安裝之二 在centos 7上安裝kafka kafka安裝之三 spring kafka實踐 zookeeper是乙個分布式的,開放原始碼的分布式應用程式協調服務,是google的chubby乙個開源的實現,是hadoop和hbase的重要元件。它...