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 d08f787771 [ISSUE #9807] Optimize log.warn Time Consumption in the 
send Method (#9808)
d08f787771 is described below

commit d08f7877711571fa7b04e38fe9ac95c8fc1c81f2
Author: yx9o <[email protected]>
AuthorDate: Wed Nov 19 16:05:36 2025 +0800

    [ISSUE #9807] Optimize log.warn Time Consumption in the send Method (#9808)
---
 .../apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java   | 4 +++-
 1 file changed, 3 insertions(+), 1 deletion(-)

diff --git 
a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
 
b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
index b54091e3ce..b6af66b67b 100644
--- 
a/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
+++ 
b/client/src/main/java/org/apache/rocketmq/client/impl/producer/DefaultMQProducerImpl.java
@@ -809,7 +809,9 @@ public class DefaultMQProducerImpl implements 
MQProducerInner {
                         endTimestamp = System.currentTimeMillis();
                         this.updateFaultItem(mq.getBrokerName(), endTimestamp 
- beginTimestampPrev, false, true);
                         log.warn("sendKernelImpl exception, resend at once, 
InvokeID: {}, RT: {}ms, Broker: {}", invokeID, endTimestamp - 
beginTimestampPrev, mq, e);
-                        log.warn(msg.toString());
+                        if (log.isDebugEnabled()) {
+                            log.debug(msg.toString());
+                        }
                         exception = e;
                         continue;
                     } catch (RemotingException e) {

Reply via email to