Kafka消费者之消费者组的概念

1. P2P模式

每个consumer都要属于一个consumer.group,就是一个消费者组,topic的一个分区只会分配给一个消费者组下面的一个consumer来进行处理,每个consumer可能会分配多个分区,也可能某个consumer没有分配到任何分区

2. 广播模式

如果想要实现一个广播的效果,那么只需要使用不同的 group id去消费就可以了

3. 总结

Kafka消费者之消费者组的概念

如果comusmer group 中的某个消费者挂了,此时会自动把分配给他的分区交给其他的消费者,如果他又重启了,那么会把一些分区重新交给他,假如我们有三个分区,两个消费者,那么其中一个消费者会消费两个分区的数据,同一个消费者组下面的消费者,不能同时消费一个分区的数据