Kafka 核心技术与实战学习笔记(十五) 消费者组
一.消费者组
消费者组: Consumer GRoup
kafka提供可扩容且具有容错性的消费机制组内有多个消费者和消费者 实例(Consumer Instance),共享公共ID(Group ID)组内的所有消费者协调在一起消费订阅主题(Subscribed Topics)的所有分区(Partition)每个分区只能由同一个消费者组内的一个Consumer实例来消费。
Consunmer Group 可以有一个或多个Consumer实例。
这里的实例是一个单独的进程,也可以是统一进程下的线程。实际场景,使用进程更为常见。Group ID 是一个字符串,在一个kafka集群中,它标识唯一一个Consumer Group。 Consunmer Group 下所有实例订阅的主题的单个分区,只能分配给组内某个Consumer实例消费。这个分区当然也被其他的Group消费。
二.传统两种模型:
点对点模型/订阅模型
传统消息缺陷:
一旦被消费,就会从队列中被删除,只能被下游的一个Consumer消费;
订阅模型
下游多个
版权声明:
作者:zhangchen
链接:https://www.techfm.club/p/28953.html
来源:TechFM
文章版权归作者所有,未经允许请勿转载。
THE END
二维码
共有 0 条评论