**
什么是Kafka消费者组**
什么是consumer group?consumer group是kafka提供的可扩展且具有容错性的消费者机制。既然是一个组,那么组内可以有多个消费者或消费者实例(consumer instance),共享一个公共的ID,即group ID。组内的所有消费者协调在一起来消费订阅主题(subscribed topics)的所有分区(partition)。当然,每个分区只能由同一个消费组内的一个consumer来消费。
其实记住这三个特性就可以理解Kafka消费者组了
- consumer group下可以有一个或多个consumer instance,consumer instance可以是一个进程,也可以是一个线程
- group.id是一个字符串,唯一标识一个consumer group
- consumer group下订阅的topic下的每个分区只能分配给某个group下的一个consumer(当然该分区还可以被分配给其他group)
希望可以帮助你理解
摘抄出处:https://www.cnblogs.com/huxi2b/p/6223228.html
欢迎分享,转载请注明来源:内存溢出
评论列表(0条)