Flink+Kafka的JavaAPI应用

时间:2022-05-30 15:54:15
【文件属性】:
文件名称:Flink+Kafka的JavaAPI应用
文件大小:37KB
文件格式:ZIP
更新时间:2022-05-30 15:54:15
bigdata flink kafka 流处理 javaapi 此案例使用的是IDEA开发工具,项目属于maven项目 使用JavaAPI操作Flink的流处理,Flink从Kafka中获取数据,执行处理后再执行输出。 根据(《Flink入门与实战》徐葳著)教材最后的综合案例改变,适合没有学习不会使用Flume的人使用
【文件预览】:
FlinkKafkaDemo
----pom.xml(5KB)
----target()
--------generated-sources()
--------classes()
----src()
--------test()
--------main()
----.idea()
--------uiDesigner.xml(9KB)
--------$PRODUCT_WORKSPACE_FILE$(1KB)
--------workspace.xml(7KB)
--------encodings.xml(182B)
--------misc.xml(526B)
--------compiler.xml(547B)
--------codeStyles()
----FlinkKafkaDemo.iml(81B)

网友评论