消费者组

消费者组是Kafka实现单播和广播两种消息模型的手段。同一个topic,每个消费者组都可以拿到相同的全部数据(不论topic有几个分区)。

单个消费者组

  • topic单分区partition,同一个消费者组中有两个消费者(单播模式)

kafka的分区和消费者组

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

  • topic三分区,同一个消费者组创建2个消费者

kafka的分区和消费者组

这说明:当分区数多于消费者数的时候,有的消费者对应多个分区

  • topic三分区,同一个消费者组创建3个消费者

kafka的分区和消费者组

这说明:当分区数等于消费者数的时候,每个消费者对应一个分区

多个消费者组

创建两个消费者组,每个消费者组一个消费者(广播模式)

kafka的分区和消费者组

这说明:启动多个组,相同的数据会被不同组的消费者消费多次

 

相关文章: