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

来源:7-7 Consumer多线程并发处理

后端Bug开发工程师

2021-05-08

http://img.mukewang.com/szimg/60963af6094f993207770357.jpg

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

http://img.mukewang.com/szimg/60963c5709182f5f13570821.jpg

写回答

3回答

Allen

2021-05-08

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

1
4
后端Bug开发工程师
非常感谢!
2021-05-11
共4条回复

后端Bug开发工程师

提问者

2021-05-12

//img.mukewang.com/szimg/609b33f4093a839a07640151.jpg

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

3
1
认真努力小封同学
牛逼,我的好哥们儿
2022-01-29
共1条回复

后端Bug开发工程师

提问者

2021-05-11

//img.mukewang.com/szimg/609a80110908bede09290324.jpg

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

0
0

Kafka多维度系统精讲,从入门到实战开发

系统讲解Kafka,实战结合,让你成为使用Kafka的高手

896 学习 · 237 问题

查看课程