第 11 章 · 消费者组与 Rebalance 可视化

4 种分区策略对比 · Eager vs Cooperative 时序 · Static Membership 实战

① 输入

C1 C2 C3 C4 无人消费

RangeAssignor

按 Consumer 字典序在每个 Topic 内分段。多 Topic 时容易出现某个 Consumer 多接管 1 分区,跨 Topic 累积放大。

RoundRobinAssignor

把所有 (topic, partition) 展开排序,依次轮询发给 Consumer。要求所有 Consumer 订阅完全相同的 Topic 集合。

StickyAssignor

初始分配同 RoundRobin;Rebalance 时尽量保留每个 Consumer 原来的分区,仅迁移少量。

CooperativeStickyAssignor(推荐)

分配结果与 Sticky 相同,但 Rebalance 过程是「增量」的(详见 Tab 2)。