代码之家 › 专栏 › 技术社区 › bdparrish

Kafka群集未接收消息

apache-kafka java

bdparrish · 技术社区 · 6 年前

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

我应该寻找什么来解决此问题?

1 回复 | 直到 6 年前

OneCricketeer Gabriele Mariotti 6 年前

终于在网络深处找到了答案。。。

我没有设置监听器,所以它使用的是规范的主机名,而不是我连接的ip地址,所以在添加ip地址作为监听器后,一切都正常。

明确地

 listeners=PLAINTEXT://<ip address here>:9092

推荐文章

yershalom · 同一消费群体中具有不同分区数量的不同卡夫卡主题

2 年前

Oskars Apinis · 将kafka从服务器迁移到docker容器

3 年前

Sravan Kumar · Apache kafka模式注册表问题

3 年前

Panadol Chong · 无法建立到节点1(localhost/127.0.0.1:9092)的连接。经纪人可能不在。甚至传入正确的端点[重复]

3 年前

MrSham · 如何确保旧版本0.10.0在卡夫卡中只处理一次

3 年前

TheTags · Kafka-PLC4X-Modbus/TCP-作业刮取期间异常

3 年前

Iheb Mar · 卡夫卡制作人/消费者粉碎每一秒的API调用

3 年前

hasherBaba · 在为Nifi编写流媒体服务时,如何解决Java的空指针异常?[闭门]

6 年前

phaigeim · 为storm consumer检查卡夫卡主题的偏移量

6 年前

Raman · Kafka流:POJO序列化/反序列化

6 年前