更新时间： 2023-06-07 07:38:12

#kafka 分区分配策略 partition strategy

RangeAssignor
假设n = 分区数 / 消费者数量，m = 分区数 % 消费者线程数量，那么前m个消费者每个分配n+1个分区，后面的（消费者线程数量 - m）个消费者每个分配n个分区。如果多个topic,
RoundRobin RoundRobinAssignor
StickyAssignor 看起来这个策略能减少rebalance带来的影响。