fixed find event position

2026-11-04 00:30:15 +08:00 · 2018-06-27 18:33:48 +08:00
parent 5f47809c8e
commit 9ae6c0c863
1 changed files with 1 additions and 1 deletions
--- 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
@@ -763,7 +763,7 @@ public class MysqlEventParser extends AbstractMysqlEventParser implements CanalE
                        }

                        if (StringUtils.equals(endPosition.getJournalName(), logfilename)
-                            && endPosition.getPosition() < logfileoffset) {
+                            && endPosition.getPosition() <= logfileoffset) {
                            return false;
                        }