kafka consumer监听消息

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

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

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

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

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

回复
回答于 6年前
半兽人
qquser -> 半兽人 6年前

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

0 0 回复
你的答案

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

找不到想要的答案？提一个您自己的问题。