kafka_demo.rar

时间:2023-04-09 10:58:53
【文件属性】:

文件名称: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)

网友评论