消费者追不上生产者:一次 Kafka 消息积压的复盘 上游促销订单量翻数倍,Kafka 消费组 lag 涨到数百万还在爬,下游报表停在两小时前。根子是消费并行度被 4 个分区锁死、单条消费 200ms。几天重构消费端:分区与消费者的铁律、扩分区扩消费者、批量消费、rebalance 与 pol… 赞 参与讨论{{item.data.meta.comment}}条讨论
消费者追不上生产者:一次 Kafka 消息积压的复盘 上游促销订单量翻数倍,Kafka 消费组 lag 涨到数百万还在爬,下游报表停在两小时前。根子是消费并行度被 4 个分区锁死、单条消费 200ms。几天重构消费端:分区与消费者的铁律、扩分区扩消费者、批量消费、rebalance 与 pol… 赞 参与讨论{{item.data.meta.comment}}条讨论
作者: 消费者追不上生产者:一次 Kafka 消息积压的复盘 上游促销订单量翻数倍,Kafka 消费组 lag 涨到数百万还在爬,下游报表停在两小时前。根子是消费并行度被 4 个分区锁死、单条消费 200ms。几天重构消费端:分区与消费者的铁律、扩分区扩消费者、批量消费、rebalance 与 pol… 赞 参与讨论{{item.data.meta.comment}}条讨论
消费者追不上生产者:一次 Kafka 消息积压的复盘 上游促销订单量翻数倍,Kafka 消费组 lag 涨到数百万还在爬,下游报表停在两小时前。根子是消费并行度被 4 个分区锁死、单条消费 200ms。几天重构消费端:分区与消费者的铁律、扩分区扩消费者、批量消费、rebalance 与 pol… 赞 参与讨论{{item.data.meta.comment}}条讨论