diff --git a/flink-cdc-runtime/src/main/java/com/ververica/cdc/runtime/serializer/data/binary/BinaryRecordDataSerializer.java b/flink-cdc-runtime/src/main/java/com/ververica/cdc/runtime/serializer/data/binary/BinaryRecordDataSerializer.java
index cb8e6a9a16a..418f4ac6a7f 100644
--- a/flink-cdc-runtime/src/main/java/com/ververica/cdc/runtime/serializer/data/binary/BinaryRecordDataSerializer.java
+++ b/flink-cdc-runtime/src/main/java/com/ververica/cdc/runtime/serializer/data/binary/BinaryRecordDataSerializer.java
@@ -95,7 +95,7 @@ public BinaryRecordData deserialize(BinaryRecordData reuse, DataInputView source
         checkArgument(
                 segments == null || (segments.length == 1 && reuse.getOffset() == 0),
                 "Reuse BinaryRecordData should have no segments or only one segment and offset start at 0.");
-
+        source.readInt();
         int length = source.readInt();
         if (segments == null || segments[0].size() < length) {
             segments = new MemorySegment[] {MemorySegmentFactory.wrap(new byte[length])};