【赵渝强老师】Kafka的消费者与消费者组原创

本节课我们来讨论一下卡夫卡的消费者与消费者组。卡夫卡是一个分布式的消息发布与订阅系统，其中的生产者producer负责发送消息，消息可以是支付串，也可以是对象，消费者consumer负责消费处理消息。这里重点讨论一下卡夫卡的消费者与消费者组。这个的主题topic中包含三个分区，分别是分区0、分区1和分区2，并且有一个消费者A，这边是卡夫卡的单消费者模型，此时消费者A将消费处理所有分区中的消息。如果卡夫卡上游生成消息数据很快超过了单个消费者的消费速度，那么就会导致消息数据的堆积。为了解决单消费者存在的问题，卡夫卡提出的消费者组的概念，在一个消费者组中可以包含多个成员，例如，这类消费者组中包含两个成员及消费者A和消费者B，他们共同消费同一个主题中的消息。需要注意的问题是，在同一个时间点上。

主题中分区的消息只能有一个消费者主中的一个消费者进行消费，而同一个分区的消息可以被不同的消费者主中的消费者进行消费。例如分区0动的消息由消费者A消费处理，而分区1和分区2中的消息由消费者B消费处理。通过这样的方式，卡发卡实现了消费者的负载均衡和失败迁移功能。现在你已经知道卡发卡的消费者与消费者主了，那你知道卡发卡的消费性有哪些消费模式吗？欢迎评论区言讨论好了记得点加号关注赵玉强老师。