You are viewing a plain text version of this content. The canonical link for it is here.

Posted to commits@rocketmq.apache.org by "DongyuanPan (via GitHub)" <gi...@apache.org> on 2023/11/01 06:06:37 UTC

Re: [I] 开启5个子线程发送5条MQ消息，MqttConsumer 只能收到4条或者更少，必现。 [rocketmq-mqtt]

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

   > 嗯嗯，好的，7511也是我提的，我们看代码找到了一个暂时的解决方式，将同一个LMQ的消息，始终发送到同一个MessageQuene中，让topic+queneid的锁能生效 ![image](https://user-images.githubusercontent.com/24490175/278995066-e3a7a3a0-a6b3-4f80-aef5-dcaff46e4cc4.png)
   
   嗯嗯，这样可以避免这个问题，目前我提交了一个修改的版本 https://github.com/apache/rocketmq/pull/7525


-- 
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-unsubscribe@rocketmq.apache.org

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