探索云世界
Flink CDC目前社区2.3版本的Debezium 是1.6.4.Final 没有考虑升级到5.1.2.Final 嘛 开启全量snapshot的时候如果locking.mode不加锁 开启snapsht的一致性事务与查询当前binlog位置并且保存 如果有write行为，就会导致数据丢失或者重复？已经设置可重复读+开启事务保证一致性
写回答
Debezium 5.1.2.Final 版本已经修复了这个问题
debezium master的代码 感觉要改改debezium了 版本更新之后有些问题就出现了，flinkx人家直接用LogMinder去解析归档日志 就没那么多事 closeResource都是自己做的，flink-cdc2.2的oracle-cdc用的就是debezium1.5.x没有发生问题，可能2.3有些特性需要用到1.6.4里面的处理功能 需要再看看，此回答整理自钉群“Flink CDC 社区”
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
