我已经建立了一个3节点的Kafka集群。这个 kafka-console-producer.sh
以及 kafka-console-consumer.sh
在本地主机的集群上按公告的方式工作,但是当我尝试从另一台服务器上的java控制台应用程序中连接到集群时,它不会向主题发送消息。我使用的是文档中的示例代码,我还尝试了github上的示例。代码似乎没有错误或异常,但消息似乎没有发送到主题。
我应该寻找什么来解决这个问题?
我已经建立了一个3节点的Kafka集群。这个 kafka-console-producer.sh
以及 kafka-console-consumer.sh
在本地主机的集群上按公告的方式工作,但是当我尝试从另一台服务器上的java控制台应用程序中连接到集群时,它不会向主题发送消息。我使用的是文档中的示例代码,我还尝试了github上的示例。代码似乎没有错误或异常,但消息似乎没有发送到主题。
我应该寻找什么来解决这个问题?
1条答案
按热度按时间jjjwad0x1#
终于在网络深处找到了答案。。。
我没有设置我的侦听器,所以它使用的是规范的主机名,而不是我正在连接的ip地址,所以在添加ip地址作为侦听器之后,一切正常。
明确地