kafka consumer监听消息

qquser 发表于: 2018-01-08   最后更新时间: 2018-01-08 17:31:39   5,887 游览

您好:又要麻烦您了,我想问一下为什么我在java端接收不到Python发送到topic里面的消息呢?之前使用activemq的时候也收不到消息,然后用用byte接收就可以收到消息。但是替换成java之后我用string或者byte都接收不到Python发送到topic里面的消息

发表于 2018-01-08
添加评论

先确定消息是否有
bin/kafka-console-consumer.sh --bootstrap-server localhost:9092 --topic test --new-consumer
接受不到消息应该不会,一般接收到会报错。

主要关注这块收到的信息是什么,打个断点:
consumer.poll(100);

qquser -> 半兽人 6年前

非常感谢,Python那边在发送消息的之前把json转换成string了。现在可以收到消息了。

你的答案

查看kafka相关的其他问题或提一个您自己的问题