[Bug] 并发异步发送消息时,报错 send request failed,导致消息无法发送
Before Creating the Bug Report
-
[X] I found a bug, not just asking a question, which should be created in GitHub Discussions.
-
[X] I have searched the GitHub Issues and GitHub Discussions of this repository and believe that this is not a duplicate.
-
[X] I have confirmed that this bug belongs to the current repository, not other repositories of RocketMQ.
Runtime platform environment
centos 7
RocketMQ version
rocketmq 5.1.3
JDK Version
openjdk1.8
Describe the Bug
使用官方的异步发送消息例子,将messageCount调成1W时,执行报错,报错信息如下
Steps to Reproduce
broker:5.1.3
client:5.1.3
使用官方的例子,异步发送报错,demo为
What Did You Expect to See?
全部发送成功
What Did You See Instead?
很多消息发送失败
Additional Context
No response
https://github.com/apache/rocketmq/pull/4601这个mr优化了这块,但是不明显,还是说我使用的有问题
看下日志中发送失败的原因是什么,大概率是触发 broker busy 了
看下日志中发送失败的原因是什么,大概率是触发 broker busy 了 broker.log中没有错误日志生成, 但是在remote.log中存在错误日志
下图是client的日志
为啥没人回复