pp (@blazeb) 在 <校招面进大厂> Kafka - 面试知识笔记 中发帖
Kafka的消费过程
1. 消费模型: push(推送模型)/pull(拉取模型)
基于push的消费系统,它指的是,由消息的生成者生成消息后,消息代理,将消息推送到消费者,推送成功就标记这个消息消费成功,这样做可以很快的对消息进行一个消费,但是很容易造成消息的丢失,比如说网络问题或者消费者进程挂了,那么对于这条消息来说是没有进行消费,就意味着这个消息它是丢失的。
基于pull的消息系统,也是kafka的选用的消费模型,消费者自己记录消费状态(Low-Level-API),这样更好的能保证消息是被消费成功的,并且消费者可以根据自身的情况来选择消费速度,也可以由消费者自己来决定消费哪个分区。另外每一个消费者消费不同的分区,不同的消费组的消费者可以拉取同一个主题的消息,并且还可以通过重置offest的方式重复消费消息。
kafka延迟队列、重试队列、死信队列
延迟队列:使用...