From 908782f056859603fe238984afd9bb530110f583 Mon Sep 17 00:00:00 2001
From: zhangjidi2016 <1017543663@qq.com>
Date: Thu, 20 May 2021 16:29:39 +0800
Subject: [PATCH] [ISSUE #2921]Fix consume msgtrace loss (#2922)

* [ISSUE #2898] Resolve rocketmq-example project failed during checkstyle execution

* [ISSUE #2921] Fix a bug in trace when consume message.
---
 .../java/org/apache/rocketmq/client/trace/TraceDataEncoder.java  | 1 +
 1 file changed, 1 insertion(+)

diff --git a/client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java b/client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java
index b2b06452..2625d353 100644
--- a/client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java
+++ b/client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java
@@ -198,6 +198,7 @@ public class TraceDataEncoder {
 
                 }
             }
+            break;
             case EndTransaction: {
                 TraceBean bean = ctx.getTraceBeans().get(0);
                 sb.append(ctx.getTraceType()).append(TraceConstants.CONTENT_SPLITOR)//
-- 
GitLab