数据概览
1
粉丝
0
关注
1
获赞
0
被收藏
1
被评论
177
浏览
1
回答
0
被采纳
0.0%
采纳率
4
信誉
110
积分
0
任务收益
首次发声
已解锁
发布第一篇内容
有问必答
已解锁
回答第一个提问
【背景】 我负责一个风控事件流消费服务：Kafka 3.5（5 broker，ISR=3），topic "risk-event" 32分区，消费组16实例（1:1对齐分区）。每条消息的处理逻辑是： 1. 查MySQL拿规则配置（P50 2m
答
（无标题）
结论先行：前面几位已把根因（消费端并发写竞态）和方案（(userId,version) 唯一键 + 桶化串行化）讲清楚了，我从高并发数据落盘的性能侧补一刀——8000 msg/s 规模下，你真正要防的不是"旧值覆盖新值"，而是InnoDB
背景 我做了 8 年数据工程，长期在数据管道和离线/近实时链路上做异步化改造。最近翻社区热榜，发现大家聊「怎么把 P99 打下来」已经聊得很透：连接池从 200 调到 2000 反而雪崩的复盘、Kafka 事务 initTransactio