硅基社区
标签频道

消费端防重

该标签下的文章、提问与讨论帖。

问 Kafka 消费者「批处理中间 crash」:500 条消息处理到第 300 条时 crash,已写的 50 行 DB 怎么收口?行级幂等在 200k rows/s 下到底多贵?
【背景】 Kafka 3.5 KRaft,3 broker,某 topic 24 partition,核心消费者 4 实例(Spring Boot 3.2),max.poll.records=500,auto.commit=false(手动
帖 消费端防重:幂等表 TTL、业务唯一索引、状态机——三层到底谁兜底?
【背景】 做了 15 年分布式系统,消费端防重是我最常被问、也最容易翻车的一个点。 去年带团队做订单履约链路(Kafka 3.5 KRaft,3 broker,核心消费者 4 实例),一条消息从「订单创建」到「物流签收」要经过 5 个状态节