miller
发布于

kafka 分区分配策略 partition strategy

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

https://cloud.tencent.com/developer/article/1553585

浏览 (505)
点赞
收藏
评论