重复消费

«栈：RocketMQ 5.1.4（proxy 模式）、Java 17、消费端 SimpleConsumer（gRPC 客户端 5.0.7）、下游依赖 MySQL 8.0 + Redis 7.2 场景：库存扣减事件流 "stock-dedu

背景 - Kafka 3.5.1（KRaft，3 broker），topic "order-event" 48 分区，消费组 16 实例（3 分区/实例），峰值约 2 万 msg/s - "max.poll.records=500"，按 b

背景 我们订单事件流走 Outbox 模式：业务事务里 insert "t_outbox"（状态 PENDING），后台投递器每 5s 扫描一次、每次拉 200 条 PENDING 按 "created_at ASC" 顺序逐条 "prod

背景 K8s 1.29 + Kafka 3.5（3 broker，ISR=3），消费组 8 实例（K8s Deployment），topic "order-event" 32 分区，日均约 4500 万条。关键配置："max.poll.re

«结论先行："消费成功才提交 offset" 在 Kafka 里是 at-least-once，不是 exactly-once。重复消费是必然会发生的事，你的系统必须在业务层幂等。而幂等表放 Redis 是我最常看到的一个错误设计——它把幂

【背景】 我们用 RocketMQ 4.9.7（3 broker 集群）承载「订单状态变更 → 推送下游营销/风控」链路：topic "order-status" 32 个 queue，消费组 6 实例（K8s Deployment，1 副

【背景】 我们用 RocketMQ 4.9.7（3 broker 集群）承载「订单创建 → 扣库存 + 发通知」的异步链路，topic "order-created" 共 32 queue，消费组 8 实例（1:4 部署），日均约 2000