阿里云文档 2025-01-27

MySQL整库同步Kafka

本文为您介绍如何将MySQL整库同步Kafka,从而降低多个任务对MySQL数据库造成的压力。

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

Flink CDC现在的场景是,库一直在新增。 那这个得一直修改,一直重启。 是不是只能这样?

Flink CDC现在的场景是,库一直在新增。 那这个得一直修改,一直重启。 是不是只能这样?

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

Flink CDC整库 如果修改了表名 怎么监控,需要重启任务吗?

Flink CDC整库 如果修改了表名 怎么监控,需要重启任务吗?

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

Flink CDC整库同步,故障重启,或者业务上如果单表刷数据这块都得自己想办法搞了吧?

Flink CDC整库同步,开源版本只能走stream api,并且没有sink端的实现,一致性,故障重启,或者业务上如果单表刷数据这块都得自己想办法搞了吧?

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

Flink CDC我是在程序里面把整库同步进行了集成,用savepoint重启任务就是报错?

问题1:Flink CDC我是在程序里面把整库同步进行了集成,程序里启停任务,现在问题是同步数据时候,以前是5张表,一个任务,现在改为7张表一个任务后,用savepoint重启任务就是报错?需要设置allowNonRestoredState参数问题2:命令方式,我也看到有,就是程序里配置,一直找不到

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

大佬们Flink CDC这个问题有遇到过吗?连从库的时候突然报错了。重启也会挂掉这个文件及位置都是存

大佬们Flink CDC这个问题有遇到过吗? 连从库的时候突然报错了。重启也会挂掉Caused by: java.lang.IllegalStateException: The connector is trying to read binlog starting at Struct{version=1.6.4.Final,connector=mysql,name=mysql_binlog_so....

问答 2023-05-14 来自:开发者社区

Flink CDC中mysql从库重启后,无法从chk启动任务,这个有人碰到过么?

Flink CDC中mysql从库重启后,无法从chk启动任务,这个有人碰到过么illegalstateexception: The connector is trying to read binlog starting at Struct{version=1.6.4.Final,connector=mysql,name=mysql_binlog_source,ts_ms=16836243397....

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

产品推荐

阿里云实时计算Flink

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

+关注