Flink CDC 菜鸟教程 -环境篇

本教程将介绍如何使用 Flink CDC 来实现这个需求，在 Flink SQL CLI 中进行，只涉及 SQL，无需一行 Java/Scala 代码，也无需安装 IDE。系统的整体架构如下图所示：

下载 flink-1.13.2 并将其解压至目录 flink-1.13.2

tar zxvf flink-1.13.2-bin-scala_2.12.tgz

✓ flink-1.13.2-bin-scala_2.12.tgz

链接：百度网盘请输入提取码提取码：az82

下载下面列出的依赖包，并将它们放到目录 flink-1.13.2/lib/ 下：

✓ flink-sql-connector-mysql-cdc-2.1.0.jar

✓ flink-sql-connector-postgres-cdc-2.1.0.jar

✓ flink-sql-connector-mongodb-cdc-2.1.0.jar

✓ flink-sql-connector-elasticsearch7_2.11-1.13.2.jar

✓ flink-sql-connector-kafka_2.12-1.13.5.jar

✓ flink-shaded-hadoop-2-uber-2.7.5-10.0.jar

标签： FlinkSQL FlinkCDC Flink CDC 运行环境

本文转载自: https://blog.csdn.net/RodJohnsonDoctor/article/details/132729804
版权归原作者 半部论语 所有，如有侵权，请联系我们删除。