kafka_demo.rar
使用flink消费kafka数据,消费过程中采用protobuf反序列化,很多案例都是一个offset对应一个消费实体,本例子中,一个offset对应一个list集合,并且sink的时候将list集合再做批量处理
下载地址
用户评论