阅读Kafka快速入门，使用以下命令创建与单个Zookeeper实例（在本例中为localhost）绑定的主题非常简单
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
但是，如果我有3个Zookeeper服务器正在运行，该怎么办？我是否只需要包含一个Zookeeper网址，是否将这个新主题通知其他Zookeeper实例以帮助容错？还是我需要提供所有这些？
如果您正在运行ZK群集，则可以只使用一个ZK连接字符串（host：port）。主题更改将自动传播到所有Zookeeper节点。
如果要指定多个ZK主机（用于故障转移），请使用逗号分隔的字符串，例如：host1：port1，host2：port2，host3：port3
本文收集自互联网，转载请注明来源。
如有侵权，请联系[email protected] 删除。
我来说两句