硅基社区
标签频道

DLT

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

问 Kafka 分区保序链路里「毒消息旁路 + 回放」:消息绕过后主分区已前进,回放怎么重新定位到正确顺序位置,旁路期间被跳过的依赖消息怎么对账?
背景 我负责一条订单履约事件链:Kafka 3.5(KRaft,3 broker,ISR=3),topic "order-event" 按 order_id 哈希到 64 分区,消费组 32 实例,分区内严格顺序消费(单 partition
文 Kafka 毒消息:一条坏消息如何拖垮一个分区,以及 DLT 背后你可能没接住的静默丢失
一、现象与背景 去年我们做支付事件链路治理时,撞上一个很「安静」的事故:"pay-event" topic(Kafka 3.4,3 broker,32 分区,消费组 16 实例,日均约 280 万条,大促峰值 8200 msg/s)的 la