卡夫卡从一台机器发送到另一台机器的消息

Question

我已经开始了本教程https://kafka.apache.org/quickstart，它在本地主机的情况下工作正常。

bin/kafka-console-producer.sh --topic quickstart-events --bootstrap-server localhost:9092

但是当我想在另一台机器上发送文本时，比如bin/kafka-控制台-Producer.sh-主题快速启动-事件-引导-服务器10.22.241.59:9092

这给了我以下的错误

​

​

WARN [Producer clientId=console-producer] Error connecting to node test-3-workernode:9092 (id: 0 rack: null) (org.apache.kafka.clients.NetworkClient)

我如何向其他机器发送消息？为什么它没有连接？

Answer 1

您需要配置代理，以便它告诉客户端连接到它的位置。这是使用advertised.listeners设置完成的。没有它，代理看起来就像默认为机器的主机名，而您的客户端无法解决这个问题。虽然客户端使用您为初始连接指定的IP地址，但它使用代理为后续连接提供的主机详细信息。

您可以在这里了解更多有关此问题的信息：https://www.confluent.io/blog/kafka-client-cannot-connect-to-broker-on-aws-on-docker-etc/