我已经设置了一个3节点的Kafka集群。kafka-console-producer.sh和kafka-console-consumer.sh按照本地主机上在集群上公布的那样工作,但是当我尝试从另一台服务器上的Java应用程序连接到集群时,它将不会向主题发送消息。我在文档中使用了示例代码,我还在GitHub上尝试了这些示例。代码似乎没有错误或异常地连接,但是消息似乎并没有发送到主题。
我应该找什么来解决这个问题呢?
发布于 2018-05-13 15:01:17
终于在网上找到了答案..。
我没有设置侦听器,所以它使用的是规范主机名,而不是我所连接的ip地址,所以在将ip地址添加到侦听器之后,它都能工作。
具体来说
listeners=PLAINTEXT://<ip address here>:9092https://stackoverflow.com/questions/50316303
复制相似问题