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

[via GitHub]

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

   
![8a02f52e-cad0-4185-8727-134b47f241f0](https://github.com/apache/rocketmq-mqtt/assets/24490175/25300017-269d-4b7c-838f-ba0a0147bd75)
   如上图，rmq5.1.4 当消息并发时，这里取了相同的offset
   
![img_v2_08eb737f-4333-453c-858e-8cc5bf71d7ag](https://github.com/apache/rocketmq-mqtt/assets/24490175/7223d39a-9bb8-4fea-96d8-825052ccbe7f)
   如上图，测试rmq5.1.4 的测试结果可以看到确实是相同


-- 
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