Flink 1.9 实战：使用 SQL 读取 Kafka 并写入 MySQL( 十 )_上周六在深圳分享了《FlinkSQL1.9.0技

FLINK_DIR=/Users/wuchong/dev/install/flink-1.9.0

下载 Kafka 2.2.0 安装包并解压：https://www.apache.org/dist/kafka/2.2.0/kafka_2.11-2.2.0.tgz

将安装路径填到 flink-sql-submit 项目的 env.sh 中，如我的路径是

KAFKA_DIR=/Users/wuchong/dev/install/kafka_2.11-2.2.0

在 flink-sql-submit 目录下运行 ./start-kafka.sh 启动 Kafka 集群。

在命令行执行 jps ，如果看到 Kafka 进程和 QuorumPeerMain 进程即表明启动成功。

可以在官方页面下载 MySQL 并安装：
https://dev.mysql.com/downloads/mysql/
如果有 Docker 环境的话，也可以直接通过 Docker 安装
https://hub.docker.com/_/mysql

$ docker pull mysql
$ docker run --name mysqldb -p 3306:3306 -e MYSQL_ROOT_PASSWORD=123456 -d mysql

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