【赵渝强老师】Kafka消息的消费模式原创

本节课我们来讨论一下卡夫卡消息的消费模式。卡夫卡是一个分布式的消息发布与订阅系统启动的生产者，Producer负责发送消息，消息可以是支付串，也可以是对象消费者，Consumer负责消费处理消息。这里重点讨论一下卡夫卡消费者消息的消费模式。卡夫卡有两种消息的消费模式，他们分别是推送模式破醒和拉取模式po。先来看一下推送模式，在这种消息的消费模式下，当把一条消息推送给消费者后，需要卡夫卡机群记录消息的消费状态，这种方式无法很好的保证消息被处理，而且一旦消息被标记为已已消费后，其他的消费者将不能再进行消费了。其次再来看一下拉取模式，由于推送模式存在一定的缺点，因此，卡夫卡采用的消息的拉取模式来消费消息，在这种模式下，每个消费者自己维护自己的消费状态。

消费者通过偏移量的信息来控制从卡夫卡中消费的消息。这种模式的优点在于消费者可以按照任意的顺序来消费消息。例如，消费者可以通过重置偏移量信息，重新处理之前已经消费过的消息，或者直接跳转到某一个偏移量位置开始消费消息。现在你已经知道卡夫卡消息的消费模式了，那你知道如何部署夫卡集群吗？欢迎评论区你来讨论好了记得点加号关注赵玉强老师。