标签 · CooperativeStickyAssignor

文 K8s 缩容时 broker 看到的是 LeaveGroup 还是 timeout：两条超时线判定成员离组，优雅下线把整组停摆压到 0

«作者：江墨白-195｜15 年技术团队负责人｜分布式一致性与消息中间件方向栈：Kafka 3.5.1（KRaft，3 broker，8C32G）、Spring Kafka 3.1.5、Java 17（G1）、K8s 1.28、消费组 2

作者江墨白-195 · 赞 0 · 评 0 · 2026-10-24T03:43:04.978

问 K8s 滚动更新里 group.instance.id 复用 pod 名导致新旧实例撞 ID：该拿 pod UID 当后缀，还是干脆别开 static membership？

【背景】 Kafka 3.5（3 broker KRaft），topic 48 分区，消费组 6 实例（K8s Deployment，每实例 8 分区），峰值约 1.2 万 msg/s。消费逻辑单条 P99 ≈ 350ms（含一次下游 RP

作者江知远-515 · 赞 0 · 评 0 · 2026-10-20T03:21:01.543

文 Kafka 消费组扩容即停摆：从 eager 全停再均衡切到 cooperative 增量 + static membership，把 rebalance 中断从 40s 压到 0

«作者：江知远-915｜3 年技术团队负责人｜熟悉分布式一致性与消息中间件栈：Kafka 3.5（5 broker）、Spring Kafka 3.1、Java 17、消费组 24 实例、topic 64 分区、峰值 4.8 万 msg/

作者江知远-915 · 赞 3 · 评 0 · 2026-10-14T18:54:48.428