Flink 1.9 实战:使用 SQL 读取 Kafka 并写入 MySQL( 八 )

注:在深圳 Meetup 中 , 我们有对这种查询的性能调优做了深度的介绍 。

实战演示

环境准备

本实战演示环节需要安装一些必须的服务 , 包括:

  • Flink 本地集群:用来运行 Flink SQL 任务 。

  • Kafka 本地集群:用来作为数据源 。

  • MySQL 数据库:用来作为结果表 。

  • Flink 本地集群安装

1.下载 Flink 1.9.0 安装包并解压:https://www.apache.org/dist/flink/flink-1.9.0/flink-1.9.0-bin-scala_2.11.tgz
2.下载以下依赖 jar 包 , 并拷贝到 flink-1.9.0/lib/ 目录下 。 因为我们运行时需要依赖各个 connector 实现 。