[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.

[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.
908782f0 · zhangjidi2016 · GitHub · b0a89596 · 908782f0
显示空白变更内容
内联并排

Showing with 1 addition and 0 deletion

client/src/main/java/org/apache/rocketmq/client/trace/TraceDataEncoder.java ...va/org/apache/rocketmq/client/trace/TraceDataEncoder.java +1 -0

未找到文件。
--- 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)//