多代理集群

Question

我正在将本教程用于 multibroker kafka 集群。我建立了三个经纪人：

• 本地主机: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

我知道该端口已被终止，但是 - 如何传递通用引导服务器以使其运行？我错过了什么？

编辑1：

后

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

它给了我信息：

警告 [Consumer clientId=consumer-1, groupId=console-consumer-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