如果不懂分区策略请看我之前的文章:https://blog.csdn.net/ywl470812087/article/details/105328015

默认的方式我们采用的是Range策略方式(按主题给消费者消费,主题被谁订阅了就谁消费)

 先看下下面这个图,画的很丑,将就看看吧

大数据技术之kafka (第 3 章 Kafka 架构深入) 分区策略在分析

我们从图知道现在有两个主题 T1  和  T2 它们都有[0,1,2]三个分区,现在有3个消费者A、B、C  

A和B是同一个组的, C单独一个组。

消费者A和B、C都订阅了主题T1   ,T2主题只有消费者B订阅了

消费的时候,因为T2主题只有B消费者订阅了,T2的3个分区都要给B消费

对于消费者C很容易理解,主题T1的3个分区只能都给C消费。

对于消费者A和B它们两个都订阅了T1,但是A和B是同一个组的,所以不能把T1主题的分区都发给A和B ,这样就重复消费了,一个主题被一个组消费两次,这时候A和B就要平均分配,3个分区2个消费者,3除以2除不尽,这样就分配不均,这样A就可能被分到主题T1的[0,1]两个分区,B负责消费分区3

相关文章:

  • 2021-05-23
  • 2021-06-29
  • 2021-11-13
  • 2021-09-09
  • 2021-04-28
  • 2022-02-11
猜你喜欢
  • 2021-08-23
  • 2021-07-30
  • 2022-12-23
  • 2021-05-20
  • 2021-06-23
  • 2021-10-26
相关资源
相似解决方案