阿里架构师:对于 Kafka 的消费者客户端详解,你都明白吗?前言一、消费者与消费者组1.1 图解消费者模型1.2 消息投递模式二、Kafka 消费者的应用2.1 消费者客户端演示2.2 必要参数配置2.3 订阅主题与分区三、消费位移3.1 什么是偏移量3.2 自动提交偏移量3.3 手动提交偏移量3.3.1 同步提交 offset3.3.2 异步提交 offset3.3.3 同步加异步提交3.4 指定位移消费3.4.1 seek 指定位移消费3.4.2 seek 指定位移消费优化3.4.3 se
前面讲解了 Kafka 的生产者,而与生产对应的就是消费者,程序中可以通过 KafkaConsumer 来订阅主题,并从订阅的主题中拉取消息。而 Kafka 中消费者比生产者多了个组的概念,也称消费者组,从而提升单机的消费速度。本文将介绍下消费者与消费者组的概念,然后再对客户端开发进行详细讲解。消费者负责订阅 Kafka 中的主题,并且从上面拉取消息,但与生产者不同的是它增加了消费者组的概念,这是因为很多时候 Kafka 的消费者在消费消息的时候经常会做一些高延时的动作,比如把数据写到数据库,读