暂无图片
用Canal从MySQL订阅同步增量数据,使用SQL语句全量导入MySQL数据之后,如何确定Canal消费的初始位移呢?
我来答
分享
Bigbig
2021-03-16
用Canal从MySQL订阅同步增量数据,使用SQL语句全量导入MySQL数据之后,如何确定Canal消费的初始位移呢?

用Canal从MySQL订阅同步增量数据,假如数据库是一直有数据进来的,使用SQL语句全量导入MySQL数据之后,如何确定Canal消费的初始位移呢?

我来答
添加附件
收藏
分享
问题补充
1条回答
默认
最新
刚阿德

按照官网的说法:
在介绍instance配置之前,先了解一下canal如何维护一份增量订阅&消费的关系信息。
参考我之前参考官网写的一篇文章:https://www.modb.pro/db/46992

一般是将位点信息持久化到zk。

我们生产环境一般是HA模式配置,类似下面官网说的:https://github.com/alibaba/canal/wiki/AdminGuide里面的“HA模式配置”。

image.png

image.png
可以看到binlog和位点信息,或者时间戳信息。

我们一般根据时间戳恢复。
image.png

暂无图片 评论
暂无图片 有用 0
打赏 0
暂无图片
回答交流
Markdown


请输入正文
提交
相关推荐
上十亿条mysql数据,分成40个表,如何去重? 现在有十亿条数据,存储在mysql数据中,分成了49个表,每个表大概4000万条,采用每条数据去分别判断所有表效率太低太低了,有什么方法可以用最快方法去重,只保留一条数据。
回答 1
已采纳
1.这里应该有主键和唯一键的标识位字段:要是有主键,唯一键把数据到导入到一张表,进行having操作即可。2.要是没有唯一标识,只能一条一条对比。可以使用pythonpandas脚本进行匹配。
msyql--8.0.18下持久化参数的bug
回答 1
在MySQL中,innodbbufferpoolsize 是用来配置InnoDB存储引擎的缓冲池大小的参数。这个参数对于MySQL的性能至关重要,因为它决定了InnoDB用来缓存表数据和索引
求mos 文档 Doc ID 2479980.1
回答 2
ForBLOBtype,itispossibletomigratebyconvertingittoahexadecimalcharacterstringandthenloadingit.Whendum
mysql中,一个普通表可以最多建立多少个分区呢?
回答 1
一个表最多1024个分区,5.7支持8196个分区
MySQL是不是整库备份之后就无法再单独使用?
回答 1
已采纳
可以使用
MySQL数据库创建索引的注意事项是什么?
回答 1
已采纳
索引的注意事项主要包括以下几点:1)不在低基数列上创建索引。2)不在索引列进行数学运算和函数运算,因为对索引字段执行函数操作可能会导致无法使用索引。3)索引不宜过多,单表索引过多不仅占空间,还会影响数
5.7并行复制,Commit-Parent-Based 和 Lock-Based 方案 的区别?
回答 1
binlogtransactiondependencytracking指定基于何种方案决定事务的依赖关系。对于同一个事务,不同的方案可生成不同的lastcommitted。该参数有以下取值:COMMI
mysql语句是否正确? select * from table having name='aa';
回答 4
已采纳
这个肯定是正确的。having可以拿来当where使用的
在navicat执行sql的耗时为什么显示两个时间?
回答 2
有时第二个时间比第一个时间大很多,是为什么呢?
什么软件可以收集mysql慢查询?
回答 1
如果只是收集的话,可以用filebeat