kafka consumer group

什么是 consumer group? 一言以蔽之，consumer group 是 kafka 提供的可扩展且具有容错性的消费者机制。既然是一个组，那么组内必然可以有多个消费者或消费者实例(consumer instance)，它们共享一个公共的 ID，即 group ID。组内的所有消费者协调在一起来消费订阅主题(subscribed topics)的所有分区(partition)。当然，每个分区只能由同一个消费组内的一个 consumer 来消费。（网上文章中说到此处各种炫目多彩的图就会紧跟着抛出来，我这里就不画了，请原谅）。个人认为，理解 consumer group 记住下面这三个特性就好了：

• consumer group 下可以有一个或多个 consumer instance，consumer instance 可以是一个进程，也可以是一个线程

• group.id 是一个字符串，唯一标识一个 consumer group

• consumer group 下订阅的 topic 下的每个分区只能分配给某个 group 下的一个 consumer(当然该分区还可以被分配给其他 group)

https://www.cnblogs.com/rainwang/p/7496147.html