最新版Flink CDC MySQL同步MySQL（一）_flink 连接mysql(1)_flink cdc 实现实时mysql数据监控,并同步到mysql

作者：很楠不爱3 | 2024-06-09 04:15:15

踩

flink cdc 实现实时mysql数据监控,并同步到mysql

下载连接器 SQL jar （或自行构建）。

将下载的jar包放在FLINK_HOME/lib/.

重启Flink集群。

注意：目前2.4以上版本需要进行自行编译构建。本文笔者自行进行构建上传的

本教程将展示如何使用 Flink CDC 快速构建 MySQL的流式 ETL。

假设我们将产品数据存储在MySQL中，同步到另外一个MySQL中

在下面的章节中，我们将介绍如何使用 Flink Mysql CDC 来实现它。本教程中的所有练习均在 Flink SQL CLI 中进行，整个过程使用标准 SQL 语法，无需任何 Java/Scala 代码，也无需安装 IDE。

架构概述如下：
在这里插入图片描述

需要准备安装好的MySQL数据库，具体MySQL数据怎么安装请查看笔者的博客Ubuntu数据库安装（mysql）

注意： 如果是其他操作系统请查看其他博客对应的数据库安装教程

声明：本文内容由网友自发贡献，不代表【wpsshop博客】立场，版权归原作者所有，本站不承担相应法律责任。如您发现有侵权的内容，请联系我们。转载请注明出处：https://www.wpsshop.cn/w/很楠不爱3/article/detail/692560