kafka消费组
1、同一个topic,每个消费者组都可以拿到相同的全部数据。2、消费者多于分区数:2.1 创建一个测试用的单分区topic-test2.2 创建一个分组group12.3 在group1中启动两个消费者producer:a,b,cconsumer1:无consumer2:a,b,c结论:同一分区内的消息只能被同一组中的一个消费者消费,当消费者的数量多于分区数量时,多于的消费者空闲(不能消费数据)。
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
结论:启动多个组,相同数据会被不同组的消费者消费多次。
更多推荐
所有评论(0)