[rocketmq] branch develop updated: [ISSUE 3420]rocketmq_client.log will not record the asynchronous sending failure exception，will only throw out the reason for the final time failure to the business (#3421)

[du...@apache.org]

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

duhengforever 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 78443c3  [ISSUE 3420]rocketmq_client.log will not record the asynchronous sending failure exception，will only throw out the reason for the final time failure to the business (#3421)
78443c3 is described below

commit 78443c3a7cf1db54b1e5f1c9b2361b89a632147d
Author: panzhi <pa...@qq.com>
AuthorDate: Tue Oct 26 13:58:29 2021 +0800

    [ISSUE 3420]rocketmq_client.log will not record the asynchronous sending failure exception，will only throw out the reason for the final time failure to the business (#3421)
---
 .../main/java/org/apache/rocketmq/client/impl/MQClientAPIImpl.java    | 4 ++--
 1 file changed, 2 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 b769429..b189c82 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
@@ -605,8 +605,8 @@ public class MQClientAPIImpl {
                 retryBrokerName = mqChosen.getBrokerName();
             }
             String addr = instance.findBrokerAddressInPublish(retryBrokerName);
-            log.info("async send msg by retry {} times. topic={}, brokerAddr={}, brokerName={}", tmp, msg.getTopic(), addr,
-                retryBrokerName);
+            log.warn(String.format("async send msg by retry {} times. topic={}, brokerAddr={}, brokerName={}", tmp, msg.getTopic(), addr,
+                retryBrokerName), e);
             try {
                 request.setOpaque(RemotingCommand.createNewRequestId());
                 sendMessageAsync(addr, retryBrokerName, msg, timeoutMillis, request, sendCallback, topicPublishInfo, instance,