diff --git a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/v0msg/CodecTextMsg.java b/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/v0msg/CodecTextMsg.java
index 68fb139957..ed50680aeb 100644
--- a/inlong-dataproxy/dataproxy-source/src/main/java/org/apache/inlong/dataproxy/source/v0msg/CodecTextMsg.java
+++ b/inlong-dataproxy/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) {