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