从0到1构建一个Flink SQL流式计算平台
1.引入pom 文件2.读kafka 数据sink 到mysql 里面sink mysql 出现相关问题处理参考:flink-table-connector-mysql-sink,程序直接退出,不报错,数据没sink到mysql表中 - 代码先锋网 (codeleading.com)3.读kafka 数据sink 到kafka4.读kafka 数据print可通过可配置话的方式去实现,sql 放在
·
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)
代码:
更多推荐
已为社区贡献6条内容
所有评论(0)