Flink 1.12 SQL Demo: 使用Java和Flink SQL，涉及MySQL等组件的示例代码

简介：
本Demo展示如何在Flink 1.12中使用Java编写SQL处理程序，涵盖与MySQL数据库交互等内容，适合初学者快速上手。 本段落介绍使用Flink 1.12.1进行SQL演示的个人练习项目。代码内置数据生成示例，并附带合适的数据展示。pom.xml文件包含了大部分必要的依赖，因此Maven下载过程可能会耗时较长。当前项目的开发环境为Windows 10 LTSC版、MySQL 8.0.23和Idea社区版2020.3。 项目内容包括使用streamset API编写Flink程序，并通过Flink SQL实现ETL功能，涉及从Mysql和Kafka读取数据以及将处理后的结果写回到Mysql的操作。具体来说，源端可以是MySQL数据库或通过MySQL CDC获取的数据流，目标则是将处理过的数据写入到另一个MySQL实例中。 要开始使用该项目，请先克隆仓库至本地环境（无需指定具体的git命令），然后在Idea中打开项目并利用maven下载所有所需的依赖。当这些准备工作完成后，可以运行demo进行测试。