Mor*_*yon 3 apache-kafka apache-zookeeper
通过Kafka 快速入门阅读,使用命令创建一个绑定到单个Zookeeper实例(在本例中为localhost)的主题非常简单
bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 1 --partitions 1 --topic test
但是,如果我有3台Zookeeper服务器在运行怎么办？我是否只需要包含一个Zookeeper URL,并且其他Zookeeper实例是否会收到有关这个新主题的通知以帮助容错？或者我需要提供所有这些吗？
如果您正在运行ZK群集,则只能使用一个ZK连接字符串(host:port).主题更改将自动传播到所有zookeeper节点.
如果要指定多个ZK主机(用于故障转移),请使用逗号分隔的字符串,如:host1:port1,host2:port2,host3:port3
| 归档时间： |
|
| 查看次数： |
3472 次 |
| 最近记录： |