kafka 主动消费_Kafka消费者 之 如何进行消息消费

前言

由于消费者模块的知识涉及太多，所以决定先按模块来整理知识，最后再进行知识模块汇总。

一、消息消费

1、poll()

Kafka 中的消费是基于拉模式的，即消费者主动向服务端发起请求来拉取消息。Kakfa 中的消息消费是一个不断轮询的过程，消费者所要做的就是重复地调用 poll() 方法，而 poll() 方法返回的是所订阅主题(或分区)上的一组消息。一旦消费者订阅了主题(或分区)，轮询就会处理所有细节，包括群组协调、分区再均衡、发送心跳和获取数据。

对于 poll() 方法而言，如果某些分区中没有可供消费的消息，那么此分区对应的消息拉取的结果就为空；如果订阅的所有分区中都没有可供消费的消息，那么 poll() 方法返回为空的消息集合。

poll() 方法的具体定义如下：

public ConsumerRecords poll(long timeout)

注意到 poll() 方法里还有一个超时时间参数 timeout ，用来控制 poll() 方法的阻塞时间。在 Kafka 2.0.0之前的版本中，timeout 参数类型为 long ；Kafka 2.0.0之后的版本中，timeout 参数的类型为 Duration ，它是 JDK8 中新增的一个与时间相关的模型。

public ConsumerRecords poll(final Duration timeout)

poll(long) 方法中 timeout 的时间单位固定为毫秒，而poll(Duration) 方法可以根据 Duration 中的 ofMillis()、ofSeconds()、ofMinutes()、ofHours() 等多种不同的方法指定不同的时间单位，灵活性更强。