diff --git a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java
index 35e98f73..4d7b0a64 100644
--- a/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java
+++ b/parse/src/main/java/com/alibaba/otter/canal/parse/inbound/mysql/MysqlEventParser.java
@@ -813,7 +813,9 @@ public class MysqlEventParser extends AbstractMysqlEventParser implements CanalE
         }
 
         if (logPosition.getPostion() != null) {
-            return logPosition.getPostion();
+            EntryPosition position = logPosition.getPostion();
+            position.setGtid(endPosition.getGtid());
+            return position;
         } else {
             return null;
         }