[INLONG-11434][DataProxy] Fix the message body of msgType=5 is incorr…

…ect (#11435) Co-authored-by: gosonzhang <[email protected]>
apache · Oct 29, 2024 · b841be1 · b841be1
1 parent a6ccb74
commit b841be1
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/...dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/v0msg/CodecTextMsg.java b/...dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/v0msg/CodecTextMsg.java
@@ -256,7 +256,7 @@ public Event encEventPackage(BaseSource source, Channel channel) {
                 }
                 byte[] record = new byte[singleMsgLen];
                 bodyBuffer.get(record);
-                inLongMsg.addMsg(mapJoiner.join(attrMap), bodyBuffer);
+                inLongMsg.addMsg(mapJoiner.join(attrMap), record);
                 calcCnt++;
             }
             if (calcCnt != this.msgCount) {