开发者社区 问答 正文

关于持久化到文件或ZK的时间间隔问题 #

我这边测试,发现如果将canal.zookeeper.flush.period或者canal.file.flush.period这两个时间间隔设久一点,由于Client的cursor信息还在内存中没有持久化到文件或者ZK,那么重启Canal或者HA切换至另一个节点会收到重复数据。我想问的是,直连Canal,是否客户端要自己做消息去重的逻辑?我目前想到的是根据binlog的position?

原提问者GitHub用户matrixtk

展开
收起
绿子直子 2023-05-09 15:57:04 107 分享 版权
1 条回答
写回答
取消 提交回答
  • 是的,会有重复,去重的思路基本正确

    原回答者GitHub用户agapple

    2023-05-10 10:52:29
    赞同 展开评论
问答分类:
问答地址: