5、分区消费模型和组消费模型

一、分区消费模型 分区消费模型： 4个分区4个消费者实例，如图所示，一个分区对应一个消费者。 步骤： 1、获取分区数个数 2、为每一个分区创建一个消费线程或进程，对应一个消费者实例 3、每一个消费者实例工作内容： （1）创建kafka实例的连接（主机名和端口） （2）指定消费者参数（对应topic的哪个partition分区） （3）设置消费的偏移量（主题的某分区的哪个偏移量号开始-每条消息对应一

>>阅读原文<<