rocketmq 5.2.0 + mqtt 1.0.2 启动mqtt会报大量的TopicUtils.decode空指针，并且通过arthas查看是反复消费推送MessageEvent -> brokerName=@String[MacBook-Pro.local]，其他信息都为空，这个是我配置问题还是代码问题？

apache / rocketmq-mqtt

Apache rocketmq

https://rocketmq.apache.org/

Apache License 2.0

182 stars 65 forks source link

Closed fengzhaowang closed 4 months ago

DongyuanPan commented 4 months ago

rmq 5.2.0 is not yet compatible with rocketmq-mqtt, but this error will not be thrown. It should be a configuration and usage issue

fengzhaowang commented 4 months ago

那我应该用哪个版本的rocketmq去配合1.0.1的mqtt去使用

ChangingFond commented 4 months ago

@fengzhaowang you can use rocketmq 5.1.4

fengzhaowang commented 4 months ago

mqtt问题重现操作.txt 问题还依然在，已经换成5.1.4版本，具体操作放在附件中

fengzhaowang commented 4 months ago

出现这个问题我寻找代码是下面代码导致的，7001端口接收的消息的PubTopic为空，导致空指针，如下：企业微信20240701-134157 企业微信20240701-134253 我暂时解决的办法为：企业微信20240701-134624 暂时没有报错，业务也正常运行，不知道是否可以这样做？

DongyuanPan commented 4 months ago

出现这个问题我寻找代码是下面代码导致的，7001端口接收的消息的PubTopic为空，导致空指针，如下：我暂时解决的办法为：暂时没有报错，业务也正常运行，不知道是否可以这样做？

plz use rocketmq-mqtt develop branch to have a try

DongyuanPan commented 4 months ago

PubTopic is seted in NotifyManager#setPubTopic(), You can check in there Why is PubTopic empty

DongyuanPan commented 4 months ago

I used rocketmq 5.1.4 + RocketMQ-MQTT develop branch to reproduce, and did not reproduce this error

DongyuanPan commented 4 months ago

fengzhaowang commented 4 months ago

有重试停止mqtt的meta和mqtt服务，继续向rmq中发消息，发完消息再启动mqtt吗

DongyuanPan commented 4 months ago

有重试停止mqtt的meta和mqtt服务，继续向rmq中发消息，发完消息再启动mqtt吗

yes

fengzhaowang commented 4 months ago

使用rocketmq 5.1.4 + RocketMQ-MQTT develop branch已解决问题