消息重放

«结论先行：线上事故要补消息，绝不要直接在生产消费组上 seek。正确姿势是拉一个全新的独立 replay 消费组，把它的位点 seek 到目标时间戳，限速重放，靠业务层幂等兜底。这套东西我们跑了三年，下面把每个坑都讲透。» 一、现象与背景

【背景】 我做订单履约服务，Kafka 3.5（3 节点），topic "order-fulfill" 16 分区，实时消费组 8 实例，日均约 4000 万条，消费逻辑是「读 batch → 写 MySQL 8.0 → 提交 offset