1、同一个topic,每个消费者组都可以拿到相同的全部数据。

2、消费者多于分区数:

2.1 创建一个测试用的单分区topic-test

2.2 创建一个分组group1

2.3 在group1中启动两个消费者

producer:a,b,c

consumer1:无

consumer2:a,b,c

结论:同一分区内的消息只能被同一组中的一个消费者消费,当消费者的数量多于分区数量时,多于的消费者空闲(不能消费数据)。

3、消费者小于和等于分区数

3.1 创建一个三分区的topictest2

3.2 在group1中启动两个消费者

producer:a,b,c,d,e,f

consumer1:b,e

consumer2:a,c,d,f

结论:当分区数多于消费者数的时候,有的消费者对应多个分区。

3.3在group1中启动3个消费者测试

producer:a,b,c,d,e,f

consumer1:b,e

consumer2:c,f

consumer3:a,d

结论:当分区数等于消费者数时候,每个消费者对应一个分区。

4、多消费者组

4.1、命名一个新的消费者组group2 

producer:a,b,c

consumer1:a,b,c

consumer2:a,b,c

结论:启动多个组,相同数据会被不同组的消费者消费多次。

Logo

为开发者提供学习成长、分享交流、生态实践、资源工具等服务,帮助开发者快速成长。

更多推荐