如果需要从两个小时前的某个时间点重新消费数据并重新处理一遍，你会如何实现？

Question

Accepted Answer

考察点：考察消息重放、回溯消费与幂等处理的工程能力。回答思路：说明如何定位并重新消费指定时间窗口的数据 阐述避免重复处理或重复写入的幂等机制 讨论乱序、迟到数据与进度对齐的处理 提及消费偏移量或位点重置的具体做法

考察说明