flink+flinkcdc+同步(MYSQL到MYSQL)实践

flink+flinkcdc+同步MYSQL到MYSQL

目的

• 通过Flink +FlinkCDC实现MYSQL到MYSQL的同步【单表，多表】
  

运行环境

1. mysql8.0.3 | flink-1.13.2 | flink-connector-jdbc_2.11-1.13.2.jar |flink-sql-connector-mysql-cdc-2.1.0.jar

复制代码

前置条件

开启bin_log日志 以及设置bin_log格式=ROW，不认识的请参考作者mysql 怎样开启bin_log日志的文章
步调

要在 Apache Flink 中使用 MySQL CDC 毗连器来同步 MySQL 数据库到另一个 MySQL 数据库，你需要下载相干的 JAR 文件。下面是获取所需 JAR 文件的步调：
步调 1: 获取 Flink 和 Flink CDC 毗连器 JAR 文件

• 下载 Apache Flink:
  
     <  
  
  
  

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。