Kafka在zookeeper中儲存的資訊

2021-10-20 17:46:53 字數 1409 閱讀 1819

/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的重要元件。它...