开发者社区> 问答> 正文

binlog 到canal server 等组件的时序

]) 关于canal 的时序,有几点想了解一下

parser/sink依赖的位点管理选择了持久化模式,是用zookeeper 的方式 1.canal server 在收到binlog 后,parser 模块用zookeeper 来做持久化处理,存储上一次binlog 解析的位置,是先存储binlog 位置再发送binlog 到mq 中,还是存储位置和发送binlog 是同时进行的? 2.canal server 这边是以怎样的方式发送到下游的,是积攒了一些再向mq 发送,还是边收边发,考虑到数据量多的时候,对zookeeper 的压力会不会很多

原提问者GitHub用户xinxinzhao1212

展开
收起
山海行 2023-04-27 19:01:00 100 0
1 条回答
写回答
取消 提交回答
  • 只有客户端有消费时才会定时更新到zookeeper

    原回答者GitHub用户agapple

    2023-04-28 13:55:09
    赞同 展开评论 打赏
问答排行榜
最热
最新

相关电子书

更多
PolarDB-X 2.0 全局 Binlog 与备份恢复能 立即下载
低代码开发师(初级)实战教程 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载