开发者社区 > 大数据与机器学习 > 实时计算 Flink > 正文

flink-cdc-connector可以做到mysql数据结构动态演进吗?

flink-cdc-connector可以做到mysql数据结构动态演进吗?mysql新增了一个字段,cdc同步任务不用重启就能读到新增字段的数据吗?

展开
收起
十一0204 2023-08-09 09:53:01 48 0
2 条回答
写回答
取消 提交回答
  • 北京阿里云ACE会长

    是的,flink-cdc-connector可以支持MySQL数据结构的动态演进,即MySQL数据库表结构如新增字段等变更,不需要重启CDC任务就可以读到变更后的最新数据结构。

    这是因为flink-cdc-connector是通过读取MySQL的binlog日志来实现数据同步的。

    2023-08-11 15:21:53
    赞同 展开评论 打赏
  • 意中人就是我呀!

    社区版的sql目前不行,你可以使用ds代码来手动处理,可以在启动的时候加上ddl变更语句,阿里的ctas 和 cdas是可以的。此回答整理至钉群“Flink CDC 社区”。

    2023-08-09 12:12:33
    赞同 展开评论 打赏

实时计算Flink版是阿里云提供的全托管Serverless Flink云服务,基于 Apache Flink 构建的企业级、高性能实时大数据处理系统。提供全托管版 Flink 集群和引擎,提高作业开发运维效率。

相关产品

  • 实时计算 Flink版
  • 相关电子书

    更多
    搭建电商项目架构连接MySQL 立即下载
    搭建4层电商项目架构,实战连接MySQL 立即下载
    PolarDB MySQL引擎重磅功能及产品能力盛大发布 立即下载

    相关镜像