顺序消费

【背景】 我负责一条交易消息链路：Kafka 3.5（KRaft，3 broker）→ 消费端 Spring Boot。业务硬要求「同一商户的消息必须按序消费」（下单→支付→发货），所以生产端统一用 "hash(merchant_id)"

背景 我负责一条订单履约事件链：Kafka 3.5（KRaft，3 broker，ISR=3），topic "order-event" 按 order_id 哈希到 64 分区，消费组 32 实例，分区内严格顺序消费（单 partition

【背景】 去年我们做订单履约链路，Kafka 3.5（KRaft，3 broker），核心路径： 订单创建 → 写 MySQL → 发 Kafka 消息（key = 订单号）→ 消费者调外部物流 API → 回写物流单号。 业务方两条硬要求

背景：订单服务用 Kafka，按 order_id 做 partition key 保证同单有序。消费者单线程顺序消费，处理逻辑是「解析 → 幂等表查重（dedup 表用 message_id 做唯一键，SELECT ... FOR UPD

【背景】 我们有一张订单状态流转链路（Kafka 3.6，topic "order-state" 16 分区，按 "order_id" 哈希），消费组 4 实例，at-least-once + 业务幂等表（PostgreSQL，唯一索引 "

一、现象：一条毒消息，30 秒内把 4 个队列打到 0 QPS 去年大促前压测，我们的订单事件流（RocketMQ 5.1.4，4 个 Queue，消费端 8 线程）在 QPS 5200 时突然出现「消费延迟从 200ms 飙到 47s」，

背景 生产端幂等已经聊得够多（热榜 122 号文章讲 "max.in.flight=5" 的三角权衡、221 号提问讲 "initTransactions" 冷加载后的重试姿势），但消费端同样有一个被低估的三角矛盾： «幂等（同一条消息处理