2015-10-15 64 views
2

通過卡夫卡Quick Start閱讀,(在這種情況下是localhost)創建綁定到一個動物園管理員實例的話題是非常簡單的使用命令創建卡夫卡話題多飼養員實例

bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test 

但是,如果我有3個是什麼Zookeeper服務器正在運行?我是否只需要包含一個Zookeeper網址,並將其他Zookeeper實例通知給這個新主題以幫助容錯?還是我需要提供所有這些?

回答

5

如果您正在運行ZK羣集,則只能使用一個ZK連接字符串(host:port)。主題更改將自動傳播到所有動物園管理員節點。

如果你想指定多個ZK主機(故障轉移),用逗號分隔的字符串,如:主機1:端口1,主機2:端口2,主機3:端口3

+1

如果你有不同的chroot(而不是/)。是正確的格式:host1:port1,host2:port2,host3:port3/chroot或host1:port1/chroot,host2:port2/chroot,host3:port3/chroot? – andresp

+1

顯然是前者。 https://issues.apache.org/jira/browse/KAFKA-1664?focusedCommentId=14155908&page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel#comment-14155908 – andresp