Kafka - Kafka 消费者


一、kafka消费方式

kafka采取pull(拉)模式

二、消费者总体工作流程

老版本0.9之前,offset保存在zookeeper上。

新版本1.0后,每个消费者的offset又消费者提交到系统主题保存。

三、消费者组原理

3.1 原理简介

3.2 消费者组初始化过程

四、消费者API

4.1 独立消费者案例

代码示例: