一个partition不能被同一个组中的多个cusumer同时消费
来源:7-7 Consumer多线程并发处理

后端Bug开发工程师
2021-05-08
启动两个cusumer消费partition1和partition2,之前提过一个partition不能被同一个组中的多个cusumer同时消费,但是我这里打印cusumer1和cusumer2都消费到了partition1和partition2,请问老师这是什么原因呢
写回答
3回答
-
这不就是两个consumer分别消费两个partition么。。
142021-05-11 -
后端Bug开发工程师
提问者
2021-05-12
找到原因了,与subscirbe方法不同,assign的consumer不会拥有kafka的group management机制,也就是当group内消费者数量变化的时候不会有reblance行为发生。
312022-01-29 -
后端Bug开发工程师
提问者
2021-05-11
不知道是不是公司电脑的问题,家里面的电脑测出来和预想结果一致,谢谢老师
00
相似问题