1.引入pom 文件
2.读kafka 数据sink 到mysql 里面
sink mysql 出现相关问题处理参考:flink-table-connector-mysql-sink,程序直接退出,不报错,数据没sink到mysql表中 - 代码先锋网 (codeleading.com)
3.读kafka 数据sink 到kafka
4.读kafka 数据print
更多source和sink 参考:
Apache Flink 1.12 Documentation: Apache Kafka SQL Connector
可通过可配置化的方式去实现,sql 放在文件里面,然后读取文件进行解析
zhp8341/flink-streaming-platform-web: 基于flink-sql的实时流计算web平台 (github.com)
代码:
zhugezifang/flink-sql-demo (github.com)