一个partition不能被同一个组中的多个cusumer同时消费

Question

启动两个cusumer消费partition1和partition2，之前提过一个partition不能被同一个组中的多个cusumer同时消费，但是我这里打印cusumer1和cusumer2都消费到了partition1和partition2，请问老师这是什么原因呢

Answer 1

Allen 2021-05-08 16:47:50

这不就是两个consumer分别消费两个partition么。。

• 提问者 后端Bug开发工程师 #1

  我理解的是 cosumer1和comsumer2是在一个分组中的，然后topic有两个partition0和partition1，结果应该是cosumer1或者comsumer2只能消费到其中的一个partition，而不是comsumer1消费到了partition1和partition2，comsumer2也消费到了partition1和partition2，这就出现了同一个partition被同一个分组中的两个cusumer消费了

• Allen 回复 提问者 后端Bug开发工程师 #2

  你理解的没错呀，或者也有可能同一个consumer消费两个partition， 这是kafka的loadbalance决定的

• 提问者 后端Bug开发工程师 回复 Allen #3

  对的，但是我上面的代码是经典版启动的两个线程comsumer1和comsumer2，comsumer1和comsumer2都是同一个分组下的，但是控制台打印的时候comsumer1和comsumer2同时都消费到了partition1和partition2，所以就对这块有点疑问

点开查看后面1条评论

Answer 2

提问者 后端Bug开发工程师 2021-05-12 09:49:58

找到原因了，与subscirbe方法不同，assign的consumer不会拥有kafka的group management机制，也就是当group内消费者数量变化的时候不会有reblance行为发生。

• 认真努力小封同学 #1

  牛逼，我的好哥们儿

Answer 3

提问者 后端Bug开发工程师 2021-05-11 21:01:28

不知道是不是公司电脑的问题，家里面的电脑测出来和预想结果一致，谢谢老师