写文章
- @asdf1368822590
简介
该用户还未填写简介
擅长的技术栈
未填写擅长的技术栈
可提供的服务
暂无可提供的服务
关于flink kafkaconsumer的偏移量存储位置测试
偏移量存储位置：1、如果设置了状态后端和checkpoint机制，同时有下面设置：FlinkKafkaConsumer.setCommitOffsetsOnCheckpoints(true)（上面代码表示每次checkpoint的时候把组消费偏移量提交到kafka，默认为true）那么组消费偏移量会记录到 状态后端 和 kafka2、如果设置了状态后端和checkpoint机制，同时有下面设置：F
暂无文章信息