Kafka工作流程-消费过程分析

    kafka提供了两套consumer API：高级Consumer API和低级API。   1.消费模型        消息由生产者发布到Kafka集群后，会被消费者消费。消息的消费模型有两种：推送模型（push）和拉取模型（pull）。      基于推送模型（push）的消息系统，由消息代理记录消费者的消费状态。消息代理在将消息推送到消费者后，标记这条消息为已消费，但这种方式无法很好

>>阅读原文<<