search

apache / rocketmq-mqtt

Apache rocketmq
https://rocketmq.apache.org/
Apache License 2.0
181 stars 63 forks source link

mqtt demo consume error #111

Closed lxflxfeng closed 2 years ago

lxflxfeng commented 2 years ago

MqttProducer.java run sucess MqttConsumer.java connect success ,but consume error I opened rocketmq-mqtt remote port debugging and found this

image image

Hope to help solve, thank you very much

YYYYWD commented 2 years ago

I had this problem once. Maybe you can try to clear all the messages under the topic you subscribed to.