请问一下有人遇到flink cdc用mysql source重复消费的情况吗?

请问一下有人遇到flink cdc用mysql source重复消费的情况吗?

问个技术点,有大佬帮忙释疑下吗? flink cdc mysql source开了4个并发,特意指

问个技术点,有大佬帮忙释疑下吗? flink cdc mysql source开了4个并发,特意指定了一个servierId。他提示serverid范围必须大于等于source的并发度。但是快照阶段其实是读取全量表,这时候用不到从库吧。从库监听读取binlog时需要一个serverid就可以了,为什...

实时数据接入:5分钟上手 Flink MySQL 连接器

1 课时 |
204 人已学 |
免费

RDS MySQL 高效设计及性能调优

1 课时 |
802 人已学 |
免费
开发者课程背景图

请问 flink-cdc 监控mysql的多张表的时候,怎么做到source合并?我就是觉得阿里的

请问 flink-cdc 监控mysql的多张表的时候,怎么做到source合并?我就是觉得阿里的cdas 不错,那个好像就做到了多个source合并

大佬请教个问题,就是上次我说的flink cdc source mysql sink hudi,时

大佬请教个问题,就是上次我说的flink cdc source mysql sink hudi,时差多了八个小时,当时让我看MySQL的时区是Asia/Shanghai (CST,+0800)? 就是有个问题是,我这边有两个业务库,时区都是一样的,只有这个同步过来时区+8小时,另外的那个是正常的,这...

大家有运行cdc任务的时候,当遇到task失败的时候,然后mysql cdc 的source就一直报

大家有运行cdc任务的时候,当遇到task失败的时候,然后mysql cdc 的source就一直报错起不来的情况嘛?mysql cdc java.lang.RuntimeException: One or more fetchers have encountered exception

大佬们,flink cdc source的 mysql表增加字段,sink能自动增加吗

大佬们,flink cdc source的 mysql表增加字段,sink能自动增加吗

请问有没人知道mysql-cdc里面把source注册到flink-table这一块的源码实现在哪?

请问有没人知道mysql-cdc里面把source注册到flink-table这一块的源码实现在哪?

请问下,source端 mysql 表结构修改了,sink端如何同步变化?

请问下,source端 mysql 表结构修改了,sink端如何同步变化?目前CDC 在sink端表要事先建好

mysql-cdc connetor 好像不能用于sink端只能是 source端是么? Conne

mysql-cdc connetor 好像不能用于sink端只能是 source端是么? Connector 'mysql-cdc' can only be used as a source. It cannot be used as a sink.

使用Flink-sql-cdc-mysql-2.1.1作为source,Flink-sql-cdc-

使用Flink-sql-cdc-mysql-2.1.1作为source,Flink-sql-cdc-tidb-2.2.0作为sink。想要做全增量一体化数据库同步,出现以下情况 :任务启动后会将数据库存量数据一次性导入,但是增量数据要过20分钟才会开始同步,这是什么原因呢?

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

产品推荐

社区圈子

阿里云数据库
阿里云数据库
让用户数据永远在线,让数据无缝的自由流动
279459+人已加入
加入
相关电子书
更多
PolarDB-X:更具性价比的 MySQL替换
2023云栖大会:AnalyticDB MySQL新特性介绍
2023云栖大会:云数据库RDS - 年度产品发布与最佳实践
立即下载 立即下载 立即下载
相关镜像

云数据库 RDS MySQL 版source相关内容