(rocketmq) branch develop updated: [ISSUE #8168] fix: There's no need to retry when async produce already timeout (#8169)

[lizhimin]

This is an automated email from the ASF dual-hosted git repository.

lizhimin pushed a commit to branch develop
in repository https://gitbox.apache.org/repos/asf/rocketmq.git


The following commit(s) were added to refs/heads/develop by this push:
     new 9c8fdb715f [ISSUE #8168] fix: There's no need to retry when async 
produce already timeout (#8169)
9c8fdb715f is described below

commit 9c8fdb715f774440009b85da2edbd2ab0278831d
Author: Humkum <1109939...@qq.com>
AuthorDate: Fri May 24 17:01:41 2024 +0800

    [ISSUE #8168] fix: There's no need to retry when async produce already 
timeout (#8169)
---
 .../main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java   | 5 +++--
 1 file changed, 3 insertions(+), 2 deletions(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java 
b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
index 9b15279cb6..816ae877ac 100644
--- a/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
+++ b/client/src/main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java
@@ -704,9 +704,10 @@ public class MQClientAPIImpl implements 
NameServerUpdateCallback {
                         onExceptionImpl(brokerName, msg, timeoutMillis - cost, 
request, sendCallback, topicPublishInfo, instance,
                             retryTimesWhenSendFailed, times, ex, context, 
true, producer);
                     } else {
-                        MQClientException ex = new MQClientException("unknow 
reseaon", throwable);
+                        MQClientException ex = new MQClientException("unknown 
reason", throwable);
+                        boolean needRetry = !(throwable instanceof 
RemotingTooMuchRequestException);
                         onExceptionImpl(brokerName, msg, timeoutMillis - cost, 
request, sendCallback, topicPublishInfo, instance,
-                            retryTimesWhenSendFailed, times, ex, context, 
true, producer);
+                            retryTimesWhenSendFailed, times, ex, context, 
needRetry, producer);
                     }
                 }
             });