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

[via GitHub]

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

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

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