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

flinkcdc 采集mysql出现卡在某个binlog文件出不来怎么办?

flinkcdc 采集mysql出现卡在某个binlog文件出不来。 一直重复消费一个文件,看日志是先断开,在重建链接,然后消费binlog,最后Stopped reading binlog after 0 events, no new offset was recorded 。如此往复。 期间数据采集一直是重复的?

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

FlinkCdc采集Mysql数据,在多并行度情况下,如何保证数据的顺序性

场景:flinkcdc 采集Mysql的user表数据写入到kafka,然后flink再从kafka消费数据写入到StarRocks数据库里面,然后 flink设置并行度为2;如果此时user表新增了一条数据,而后又立马被删除了,那么由于flink的并行度为2可能会存在并且每个任务的处理速度不一样,比如删除的binLog发送给任务A,新增的binLog发送给任务B,那么 会存在flink的 任务....

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

在Flink CDC中使用flinkcdc采集mysql,因为采集的表特别多,有什么好的解决方案?

在Flink CDC中使用flinkcdc采集mysql,因为采集的表特别多,导致mysql侧主机IO压力较大,有什么好的解决方案?

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

flinkcdc采集mysql8.0.2表数据到doris报错

阿什顿

问答 2023-09-28 来自:开发者社区

有用flinkcdc采集mysql表的时候,mysql表里有emoji表情的嘛?这个是怎么处理的呀?

有用flinkcdc采集mysql表的时候,mysql表里有emoji表情的嘛?这个是怎么处理的呀?

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

flinkcdc采集mysql数据,写入kafka,可以单独往某个topic里面写ddl吗?

问题1:flinkcdc采集mysql数据,写入kafka,可以单独往某个topic里面写ddl吗?问题2:flinkcdc怎么单独采集ddl呢?有参考连接吗?

问答 2023-06-29 来自:开发者社区

巨佬们,请教个问题: 我使用flinkCDC 采集MySQL数据,MySQL中的binlog清理策?

巨佬们,请教个问题: 我使用flinkCDC 采集MySQL数据,MySQL中的binlog清理策略是(1.占磁盘30%;2.binlog存储超过18个小时;3.binlog文件超过60个),这种策略导致采集任务经常性找不到binlog, 请问,在不动mysql端的情况下,flink端有什么参数可以解决这个问题的吗?

阿里云文档 2023-01-29

如何使用FlinkCDC将MySQL数据同步至EMRServerlessStarRocks

本文为您介绍如何使用Flink CDC将MySQL数据同步至EMR Serverless StarRocks中。

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

云数据库 RDS MySQL 版更多flinkcdc相关

产品推荐

数据库

数据库领域前沿技术分享与交流

+关注
相关镜像
AI助理

你好,我是AI助理

可以解答问题、推荐解决方案等