介绍:
Flink实际生产过程中,需要从Kafka读取数据,处理后写入MySQL作为查询显示。 这个程序可以在本地运行flink编译源码,也可以提交给yarn来运行。 完整的 Flink 代码可以通过简单的更改直接使用。 。
该项目提供
1.项目源码和详细注释flink编译源码,简单修改即可用于实际生产代码
2、编译成功截图
3.Linux提交命令
4.将截图提交到yarn
5、编译过程中可能出现的问题
6.测试kafka连接代码
成功编译成功信息如下
[信息] --- maven-jar-plugin:2.4:jar (default-jar) @ flink-kafka-to-mysql ---
[信息] 构建 jar:D:flinkflink-kafka-to-mysqltargetflink-kafka-to-mysql-1.0-SNAPSHOT.jar
[信息]
[信息] --- maven-assemble-plugin:3.0.0:single (make-assemble) @ flink-kafka-to-mysql ---
[信息] 构建 jar:D:flinkflink-kafka-to-mysqltargetflink-kafka-to-mysql-1.0-SNAPSHOT-jar-with-dependency.jar
[信息] ---------------------------------------------------------- ------------------------
[信息] 取得成功
[信息] ---------------------------------------------------------- ------------------------
[信息] 总时间:
发表评论