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

Flink CDC有人成功通过指定的方式增量同步的吗?

Flink CDC有人成功通过指定的方式增量同步的吗?

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

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

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

高性能

Flink CDC 实现企业级实时数据同步

传统的数据集成通常由全量和增量同步两套系统构成,在全量同步完成后,还需要进一步将增量表和全量表进行合并操作,这种架构的组件构成较为复杂,系统维护困难。本方案提供 Flink CDC 技术实现了统一的增量和全量数据的实时集成。
技术解决方案背景图
问答 2023-12-24 来自:开发者社区

Flink CDC没报错,但数据不同步,修改source表数据,sink表没变,为什么?

Flink CDC通过flinksql的方式 flink 1.14.6 cdc 2.4.2 测试souce表以下两种增量同步,都没成功过,'scan.startup.mode' = 'specific-offset','scan.startup.specific-offset.file' = 'mysql-bin.000268','scan.startup.specific-offse...

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

Flink CDC没办法正常同步数据了,是我姿势不对吗?

Flink CDC没办法正常同步数据了,是我姿势不对吗?mysql 用cdc 2.4.2 souce表用 'scan.startup.mode' = 'latest-offset'可以正常同步数据,但用'scan.startup.mode' = 'timestamp','scan.startup.timestamp-millis' = '1703127600000'

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

Flink CDC有 办法 自定义 同步到 Sr 的 数据库名称吗?

Flink CDC无法 创建带 减号➖连字符的数据库名, mysql的库名又是这种格式,所以有 办法 自定义 同步到 Sr 的 数据库名称吗?

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

Flink CDC可以自定义 同步到 starrocks 的数据库名吗?

Flink CDC有个 mysql 同步到 starRocks的问题, 就是 可以自定义 同步到 starrocks 的数据库名吗?

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

Flink CDC中debezium 的 oracle同步 性能咋样,大家有测试验证么 ?

Flink CDC中debezium 的 oracle同步 性能咋样,大家有测试验证么 ?

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

Flink CDC有什么方案从mysql同步数据到mysql吗? 支持全量和增量的?

Flink CDC有什么方案从mysql同步数据到mysql吗? 支持全量和增量的?~~~~

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

oracle 用flink cdc同步日志量太大了,半小时就产生几十G的日志量,业务啥操作都没有?

oracle 用flink cdc同步日志量太大了,半小时就产生几十G的日志量,业务啥操作都没有?

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

主库业务比较关键,从库可以做Flink CDC同步吗?

主库业务比较关键,从库可以做Flink CDC同步吗?

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

产品推荐

阿里云实时计算Flink

一套基于Apache Flink构建的一站式、高性能实时大数据处理平台,广泛适用于流式数据处理、离线数据处理、DataLake计算等场景。

+关注