canal中的transaction ID获取和entry.getHeader().getLogfi

自己动手通过mysqlbinlog --hexdump可以查看到commit才有xid。 offset是字节偏移。

原回答者GitHub用户lcybo

问题1：

在 Canal 中，transactionBegin 和 rowData 都不包含 transactionId，只有 transactionEnd 包含 transactionId。因此，如果您需要获取 transactionId，建议您只从 transactionEnd 中获取。

如果您需要确定某个 row 是否属于当前 transaction，可以将 row 的 binlog 序号（binlog file offset）与 transactionBegin 和 transactionEnd 中的序号进行比较，如果 row 的序号在这两个序号之间，那么这个 row 属于当前 transaction。

问题2：

entry.getHeader().getLogfileOffset() 获取到的是当前 rowdata 在 binlog 文件中的序号（即第几条 binlog 日志），而非字节数。具体来说，该值表示当前 rowdata 在 binlog 文件中的偏移量（offset），可以唯一地标识当前 rowdata 在 binlog 文件中的位置。