2015-04-02 161 views
2

我們有一個沙箱,它有5個節點,並且所有5個節點都運行kafka代理(代理id = 0) 現在我已經複製了所有配置文件與不同的經紀編號的5個節點和日誌文件目錄使用在5節點集羣上的每個節點上設置多代理kafka

有運行

-rw-r--r-- 1 root root 5652 Apr 2 23:01 server.properties - (this one being the default) 
-rw-r--r-- 1 root root 5675 Apr 2 23:02 server1.properties 
-rw-r--r-- 1 root root 5675 Apr 2 23:02 server2.properties 

現在做我的所有5個節點新的配置文件啓動卡夫卡多個代理0

./kafka-server-start.sh config/server1.properties & ./kafka-server-start.sh config/server2.properties & 

是否每個節點都有3個三個經紀人在運行?或其3個經紀人的整體集羣? 這是如何工作?任何幫助將不勝感激??

回答

2

集羣中的每個節點都應該只有一個配置文件和卡夫卡服務器開始只應在每個節點上運行一次。例如,服務器只需要具有單個配置文件,其包含例如broker.id = 1

您每次運行kafka-server-start您正在啓動代理(即服務器)。當經紀人開始時,卡夫卡將通過ZooKeeper找到其他經紀人。這允許在集羣中添加和刪除新代理,而無需任何額外的配置文件指定集羣中的其他節點,也無需在現有節點上執行任何重新配置​​。

如果你正在運行同一節點,那麼你確實開始在同一個節點上的多個經紀人在卡夫卡服務器啓動多次,但是這不是你想要的。

+0

Thnx的響應 - 但我的意圖是要在每個羣集上運行3個代理,並且我跑了kafka服務器,每個配置文件啓動3次,因此每個節點將有3個代理 – 2015-04-03 21:47:43