Flink数据源就是mysql到mysql。不知道有没有整库同步的支持?[阿里云实时计算 Flink版]

Flink数据源就是mysql到mysql。不知道有没有整库同步的支持?

「点点赞赏,手留余香」

    还没有人赞赏,快来当第一个赞赏的人吧!
=====这是一个广告位,招租中,联系qq 78315851====
1 条回复 A 作者 M 管理员
  1. mysql的cdc connector支持多表的读,但jdbc connector应该是不支持多表的写。 所以一条语句完成应该不行, 你可以代码里面把库下的表列出来用statementSet添加多条语句执行,flink on k8s有人使用kubectl apply -f xx.yaml的方式提交任务的经验吗。 可否不用flink客户端(run-application)而使用apply -f 的方式类似于提交application模式的job上k8s,此回答整理自钉群“【③群】Apache Flink China社区”

  2. Flink支持MySQL to MySQL的数据同步,具体可以通过以下步骤实现:

    1. 安装Flink CDC插件,连接源MySQL数据库;
    2. 创建Flink CDC Source,定义源表和目标表;
    3. 编写SQL语句,实现数据同步;
    4. 启动Flink任务,开始数据同步。
      需要注意的是,在同步数据时需要注意MySQL的连接参数,确保源表和目标表之间有足够的资源进行同步。