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

有办法不重启FlinkCDC任务动态增加订阅的表吗?

有办法不重启FlinkCDC任务动态增加订阅的表吗

展开
收起
真的很搞笑 2023-11-22 08:14:58 129 0
2 条回答
写回答
取消 提交回答
  • 面对过去,不要迷离;面对未来,不必彷徨;活在今天,你只要把自己完全展示给别人看。

    是的,Flink CDC提供了动态添加订阅表的功能,可以通过修改作业的配置来完成。具体步骤如下:

    1. 修改Flink CDC作业的配置文件,增加想要订阅的新表;
    2. 将新表的配置信息发送给正在运行的任务,使其能够识别新表;
    3. 刷新Flink CDC的任务,使任务能够识别新表并开始采集数据。

    注意,这种情况下,Flink CDC会将新表视为新的数据源,并从上次采集的最晚位置开始采集数据,而不一定会从头开始采集。

    2023-11-29 14:26:33
    赞同 展开评论 打赏
  • Flink CDC 2.0版本开始支持了一项新功能,即动态添加表。这个特性允许你在不重启任务的情况下增加新的订阅表。同时,据2023年7月的消息,Flink的MySQL CDC 2.4 API也支持了动态加表和增量阶段的支持。因此,如果你正在使用这些版本的Flink CDC,那么你可以方便地在运行时添加新的表。然而,需要注意的是,每次同步一张新表时,仍然需要启动一个新的作业。

    2023-11-22 09:10:34
    赞同 1 展开评论 打赏

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

相关电子书

更多
低代码开发师(初级)实战教程 立即下载
冬季实战营第三期:MySQL数据库进阶实战 立即下载
阿里巴巴DevOps 最佳实践手册 立即下载