java - 多经纪人集群

Question

我正在使用这个 tutorial对于 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 localhost:9092,localhost:9093,localhost:9094 --from-beginning --topic my-replicated-topic

它给我消息:

WARN [Consumer clientId=consumer-1, groupId=console-consumer-82352] Connection to node -1 could not be established. Broker may not be available. (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