update语句where条件为空导致无法同步数据
使用 canal.deployer 版本1.1.6 拉取mysql8.0.25的binlog并写入kafkatopic ，另端用py程序消费kafka topic 并再写入另一个mysql 8.0.25 发现 源mysql的update语句同步到目标mysql后 对应数据没有变化。具体如下 。 元数据更改id=2 的name为 eee
目标数据库看到的是如下图
查询 目标数据库binlog 发现执行的sql语句中 where条件为 where id=‘’ ，也就是没有查询条件 。 同时 消费kafka对应topic后 发现server端写入kafka里的json格式的内容里 就没有id的字段 已经尝试更换过1.1.4 1.1.5 1.1.6版本的deployer 都没有解决问题 这个是配置问题还是什么问题呢
急求解决方法！~~~~！！！！！感谢 。
原提问者GitHub用户chengjino1
展开
收起
1
条回答
写回答
写回答
-
找到原因了 binlog_row_image=minimal 这个参数导致的 注销后默认参数为full 然后没问题了 。
原回答者GitHub用户chengjino1
2023-04-26 18:25:36赞同 展开评论 打赏
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
问答排行榜
最热
最新
推荐问答
