文章 2024-01-02 来自:开发者社区

Flink CDC 2.2.1 版本不支持通过 source 指定 binlog 或者 timestamp 的方式来做增量同步

Flink CDC 2.2.1 版本不支持通过 source 指定 binlog 或者 timestamp 的方式来做增量同步。在 Flink CDC 2.2.1 版本中,增量同步是基于数据库的 binlog 日志来实现的,而不是通过指定具体的 binlog 文件或者时间戳。 然而,Flink CDC 2.2.1 版本支持在执行 checkpoint 时...

文章 2024-01-01 来自:开发者社区

Flink CDC全库订阅binlog你们怎么配置的,我们这好像有漏数据的情况?

Flink CDC 全库订阅binlog的配置可以参考以下步骤: 配置MySQL的binlog格式为ROW。在MySQL的配置文件中添加以下内容: [mysqld] log-bin=mysql-bin binlog-format=ROW server-id=1 在Flink中创建BinlogSourceFunction,并指定要订...

问答 2024-01-01 来自:开发者社区

Flink CDC如果 1个数据库。我启动多个jar包 监听binlog 做不同的业务。怎么配置?

Flink CDC如果 1个数据库。我启动多个jar包 监听binlog 做不同的业务。怎么配置?

问答 2024-01-01 来自:开发者社区

Flink CDC全库订阅binlog你们怎么配置的,我们这好像有漏数据的情况?

Flink CDC全库订阅binlog你们怎么配置的,我们这好像有漏数据的情况?

问答 2023-12-25 来自:开发者社区

Flink CDC全量结束还是会 按照之前的binlog位点进行消费 而不是进行合并输出?

Flink CDC全量结束还是会 按照之前的binlog位点进行消费 而不是进行合并输出?那是不是其他表的binlog也会被阻塞消费呀?

问答 2023-12-25 来自:开发者社区

Flink CDC如果有很多binlog,为什么配置上这个,脚本都不同步数据了?

Flink CDC如果有很多binlog,最后指定最近的一个timestamp ,它要从头过滤掉历史Binlog,直到指定的timestamp 才开始同步,我就说,为什么配置上这个,脚本都不同步数据了?

问答 2023-12-25 来自:开发者社区

Flink CDC全量历史数据比较多,全量同步阶段时间长 会同时读取binlog进行合并输出吧?

Flink CDC全量历史数据比较多,全量同步阶段时间长 会同时读取binlog进行合并输出吧,比如新增一张表全量同步耗时三个小时,binlog文件只保留近一个小时的,会影响全量到增量的衔接么,会阻塞其它表的binlog采集么?

问答 2023-12-24 来自:开发者社区

Flink CDC我指定从mysql-bin.000268的binlog开始同步,为什么还会读?

Flink CDC中mysql-bin.000267是变更了a字段,但我是停掉同步任务的时候做的变更呢,这个时候sink是没变的,然后我指定从mysql-bin.000268的binlog开始同步,为什么还会读mysql-bin.000267?

问答 2023-12-24 来自:开发者社区

Flink CDC这个参数是指从现在数据库里存在的,最早的一个binlog开始读 是吗?

Flink CDC这个参数是指从现在数据库里存在的,最早的一个binlog开始读 是吗?

问答 2023-12-24 来自:开发者社区

Flink CDC业务库 只保留近一个小时的binlog超时间的归档到oss 有啥好的解决方法么?

Flink CDC业务库 只保留近一个小时的binlog 超时间的归档到oss 有啥好的解决方法么 cdc有没有接口能读取oss的binlog?

本页面内关键词为智能算法引擎基于机器学习所生成,如有任何问题,可在页面下方点击"联系我们"与我们沟通。