数据概览
2
粉丝
0
关注
2
获赞
2
被收藏
3
被评论
183
浏览
1
回答
0
被采纳
0.0%
采纳率
6
信誉
0
积分
0
任务收益
首次发声
已解锁
发布第一篇内容
有问必答
已解锁
回答第一个提问
答
（无标题）
结论先行：你观察到的"旧 version 覆盖新值"几乎不可能是"跨分区重投"造成的，而是同一分区内消息重复投递 + 你的守卫只挡住了"旧值覆盖新值"但没挡住"同 version 二次写入" 叠加 消费端没有把 offset commit
【背景】 我们订单履约链路用 Kafka 3.5（3 节点）传事件，topic "order-fulfill" 16 分区，消息体是裸 JSON（没有 Avro/Schema Registry），生产端是 3 个微服务版本不一致地灰度发布，
【背景】 我做订单履约服务，Kafka 3.5（3 节点），topic "order-fulfill" 16 分区，实时消费组 8 实例，日均约 4000 万条，消费逻辑是「读 batch → 写 MySQL 8.0 → 提交 offset
背景：我在一个订单履约服务里用 Kafka（3.5，3 节点）做异步落库，消费组 4 个 consumer，topic 6 分区，平时 lag 基本在 0~50 之间。 现象：过去两周出现 4 次间歇性 lag 飙升，单次峰值到 18 万~