flink+flinkcdc+同步MYSQL到MYSQL
目标
- 通过Flink +FlinkCDC实现MYSQL到MYSQL的同步【单表，多表】
运行环境
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: <
本文转载自: https://blog.csdn.net/RodJohnsonDoctor/article/details/141500314
版权归原作者 半部论语 所有， 如有侵权，请联系我们删除。
版权归原作者 半部论语 所有， 如有侵权，请联系我们删除。