一步一个脚印，一天一道面试题

首先，为什么要读过的 Kafka 数据重写读一次呢？什么场景下要怎么做呢？

答：当任务失败，从检查点Checkpoint 开始重启时，检查点的数据是之前的了，就需要跟Kafka申请回退，从Checkpoint版的 offset 的数据读，会有一点重复消费

---------------------- 分割线 -------------------------------------------- 分割线 ----------------------

那怎么重复读 Kafka 呢？
跟 Kafka 提交之前的 offset 即可

我是近未来，祝你变得更强！