多代理集群

Question

我正在为multibroker集群使用这个教程。我设立了三个经纪人：

• 本地主机:9092
• 本地主机:9093
• 本地主机:9094

并使用以下命令：bin/kafka-topics.sh --create --zookeeper localhost:2181 --replication-factor 3 --partitions 1 --topic my-replicated-topic

据我所知，如果我的一个代理死亡，另一个将仍然运行和处理消息。

问题是，如果我杀死了9092，我就不能使用以下命令：bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --from-beginning --topic my-replicated-topic

我知道端口被关闭了，但是-如何通过通用引导服务器来使其运行呢？我遗漏了什么？

EDIT1:

之后

bin/kafka-控制台-使用者.my引导-服务器本地主机:9092，localhost:9093，localhost:9094 --从一开始--主题我-复制-主题

它给了我一个信息：

警告消费者客户端=消费者-1，群be =控制台-消费者-82352连接到节点-1无法建立。可能找不到经纪人。(org.apache.kafka.clients.NetworkClient)`

控制台就停了。没有消息被读取

Answer 1

您可以在bootstrap-server中使用代理列表。

bin/kafka-console-consumer.sh --bootstrap-server localhost:9092,localhost:9093,localhost:9094 --from-beginning --topic my-replicated-topic