DongyuanPan commented on issue #221:
URL: https://github.com/apache/rocketmq-mqtt/issues/221#issuecomment-1865411002

   > > 消息无法消费,产生大量的retry消息,然后走到这儿又不被认为是mqtt消息(因为检查user 
property中没有PROPERTY_ORIGIN_MQTT_TOPIC属性)。
   > 
   > 然后,也没有PROPERTY_INNER_MULTI_DISPATCH这个属性,最终event中的topic为空。 
另一线程处理event,跑到matchClients这里,TopicUtils.decode(topic)里面未做空判断,直接NPE。
   > 
   > 话说回来,消息为啥消费不了?跑的example里面的consumer,依然无法消费。 
还有mqttx死活都连不上去,就算用example里面的签名方法处理之后,一样不行。
   
   这个问题应该是RMQ没有开启LMQ这个特性导致的;用example里面的签名方法处理之后应该是需要Base64字符串才能使用在mqttx上。
   
![image](https://github.com/apache/rocketmq-mqtt/assets/18721508/52f9a63f-3fc9-4c5c-b7b2-82838be0f871)
   只需要取前半部分的就可以了,不要输入toCharArray的。mqttx会对字符串再求一次


-- 
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.

To unsubscribe, e-mail: commits-unsubscr...@rocketmq.apache.org

For queries about this service, please contact Infrastructure at:
us...@infra.apache.org

Reply via email to