From 0720f0eb531b6545b95b530179850013adcfad91 Mon Sep 17 00:00:00 2001 From: zhangjidi2016 Date: Fri, 16 Apr 2021 17:06:48 +0800 Subject: [PATCH] [ISSUE #2538]Optimize log output when message trace saving fails --- .../apache/rocketmq/client/trace/AsyncTraceDispatcher.java | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java b/client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java index 05a95e86..8210b41c 100644 --- a/client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java +++ b/client/src/main/java/org/apache/rocketmq/client/trace/AsyncTraceDispatcher.java @@ -370,7 +370,7 @@ public class AsyncTraceDispatcher implements TraceDispatcher { @Override public void onException(Throwable e) { - log.info("send trace data ,the traceData is " + data); + log.error("send trace data failed, the traceData is {}", data, e); } }; if (traceBrokerSet.isEmpty()) { @@ -398,7 +398,7 @@ public class AsyncTraceDispatcher implements TraceDispatcher { } } catch (Exception e) { - log.info("send trace data,the traceData is" + data); + log.error("send trace data failed, the traceData is {}", data, e); } } -- GitLab