0

我已经设置了一个 3 节点 Kafka 集群。kafka-console-producer.sh和在 localhost 的集群上宣传的kafka-console-consumer.sh那样工作，但是当我尝试从另一台服务器上的 Java 控制台应用程序中连接到集群时，它不会向该主题发送消息。我正在使用文档中的示例代码，并且我也尝试了 GitHub 上的示例。代码似乎连接没有错误或异常，但消息似乎没有发送到主题。

我应该寻找什么来解决这个问题？

4

1 回答 1

0

终于在网上找到了答案……

我没有设置我的侦听器，因此它使用的是规范主机名，而不是我正在连接的 IP 地址，因此在将 IP 地址添加为侦听器之后，一切正常。

具体来说

 listeners=PLAINTEXT://<ip address here>:9092
于 2018-05-13T15:01:17.050 回答