AI 助理
备案控制台
开发者社区 问答 正文

我使用canal的HA模式运行canal但是遇到重复读取binlog

我使用canal的HA模式运行canal，在做切换测试的时候遇到主canal读取的最后一条，会在切换到从canal时还回读到，并且推送到kafka中了，请问这是一个bug还是原本的机制就是这样的，如果是，我该如何修改它。

原提问者GitHub用户nick-yangg

展开
收起
Java工程师 2023-05-03 12:46:05 123 分享 版权

版权声明：本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《阿里云开发者社区用户服务协议》和《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。

1 条回答
写回答
取消 提交回答
  • 巴拉巴拉巴拉

    重复数据是难免的

    原回答者GitHub用户agapple

    2023-05-04 16:19:34
    赞同 展开评论
问答分类：
canal 消息中间件 Kafka 云消息队列 Kafka 版
问答标签：
binlog模式 canal binlog binlog运行 binlog canal 模式binlog
问答地址：
开发者社区 > 微服务 > 问答
相关问答
canal -adapter只能适配mysql库binlog_format=row模式？
151
1
0
canal server在同步binlog日志的时候表结构发生变化改怎么处理？
337
3
0
给已有的维表开启binlog，然后再Flink中查询 一直显示运行中，没有数据；这是为什么呢？
74
1
0
canal的zookeeper里的cursor不更新binlog position
168
0
0
使用canal复制PolarDB MySQL的binlog需要什么权限
118
1
0
flink-cdc 在抽取mysql binlog，运行一段时间 source 就报java.uti
1187
3
0
请问 flinkcdc的时候 checkpoints里的mysql binlog pos不变吗？
749
10
0
大佬们，cdc mysql 可以获取binlog，binlog模式必须是row吗？
969
1
0
我的mysql的binlog已经开启了 但是flink cdc的打印显示没有读取到binlog文件，
1000
0
0
有没有遇到同步MySQL一直卡在某个binlog文件？数据库已经确认后续的binlog都生成了 io
858
0
0