文件名称:kafka_demo.rar
文件大小:11KB
文件格式:RAR
更新时间:2023-04-09 10:58:53
大数据 flink kafka
使用flink消费kafka数据,消费过程中采用protobuf反序列化, 很多案例都是一个offset对应一个消费实体,本例子中,一个offset对应一个list集合,并且sink的时候将list集合再做批量处理
【文件预览】:
kafka_demo
----src()
--------main()
--------test()
----pom.xml(5KB)