重启Canal导致数据重新写入kafka
近日canal升级漏洞安装包,重启canal Server 服务,发现同步mysql的binlog数据全部重新进入kafka一次,导致数据翻倍增加,想问一下有没有大佬遇到过这种问题,如何解决?
什么都没有修改,好像canal底层记录的一个标志位(事物id),混乱了,然后本身01机器应该消费到第十条,02机器消费到第20条,然后重启的时候全部冲第十条开始消费了.感觉没走自己值钱记录的事物id
原提问者GitHub用户Anandonzy
展开
收起
1
条回答
写回答
写回答
版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
相关问答
