前言

在上一篇我们通过代码演示，通过读取kafak的数据，然后将数据再次写出到kafka中，本篇将分享使用Flink Table Api 如何将读取到的文件的数据写出到mysql ;

业务应用

在某些场景下，通过读取源数据后，需要经过flink程序的处理，然后将数据持久化存储到数据库、或es等，作为后续其他业务继续使用

代码演示

前置准备，在resource目录下，准备一个测试用的csv文件，作为flink读取的数据的源文件，内容如下：

本例，我们将沿用上一篇的案例逻辑，通过读取csv文件，再通过Flink Table Api 的使用将读取到的数据进行聚合统计，最后将统计结果写出到mysql中，因此需要提前创建一张表；

如下是提前创建好的空表，这里有2个字段，一个是id，一个是统计结果值；