读取后记录的是事务结束的开始positon,而不是end_log_pos

环境信息

canal version 5.6 mysql version canal.deployer-1.1.2

问题描述

1、循环读取binlog时, 某个事务的事务结束事件(假设为a)也读取到并处理掉了(后续循环是空循环,不再读取到新的binlog),

2、但meta.dat中记录的是这和事务结束的开始position,

3、此时停止canal,再次启动后,运行client代码,会将a事件(事务结束事件)再读取一次

效果大致如下图: meta.dat

            "postion": {
                "gtid": "",
                "included": false,
                "journalName": "mysql-bin.000019",
                "position": 6170,
                "serverId": 1021,
                "timestamp": 1551686429000
            }

binlog:

mysql-bin.000019 5834 Query 1021 5906 BEGIN mysql-bin.000019 5906 Rows_query 1021 5999 # UPDATE boot.user_xxxxx SET password = 'barfoo' WHERE id = 2 mysql-bin.000019 5999 Table_map 1021 6063 table_id: 76 (boot.xxxxx) mysql-bin.000019 6063 Update_rows 1021 6170 table_id: 76 flags: STMT_END_F mysql-bin.000019 6170 Xid 1021 6201 COMMIT /* xid=356 */

重启canal后再次运行client:

期待结果

按照正常的想法,meta.dat中记录的应该是6201吧

原提问者GitHub用户LuVx21