1. 首页
  2. 大数据
  3. kafka
  4. kafka_demo.rar

kafka_demo.rar

上传者: 2020-05-31 13:43:45上传 RAR文件 10.6KB 热度 21次
使用flink消费kafka数据,消费过程中采用protobuf反序列化,很多案例都是一个offset对应一个消费实体,本例子中,一个offset对应一个list集合,并且sink的时候将list集合再做批量处理
用户评论