Kafka consumer.poll()方法入参的含义及生效规则

首先给出问题对应的示例代码：

ConsumerRecords<String, String> records = consumer.poll(100);

示例中传入的100单位为毫秒，是poll操作的最长阻塞超时阈值，既不是固定阻塞时长，也不是强制攒批的时间窗口，具体规则对应两个疑问解答如下：

• 针对第一个疑问：该参数既不代表“分区无数据时消费者一定会阻塞满100ms”，也不代表“消费者会持续轮询满100ms攒够时段内数据再返回”。
  实际执行逻辑是：poll方法触发后，只要满足「拿到了可返回的消费数据」、「阻塞等待时长达到传入的100ms阈值」两个条件中的任意一个，就会立刻结束阻塞返回结果。如果等待过程中（比如仅等了15ms）就拿到了broker返回的可消费数据，会直接返回这批数据，不会把剩下的85ms等满。
• 针对第二个疑问：该参数不是仅在分区无数据时生效，更不会让消费者无论有没有数据都固定阻塞100ms。
  实际生效场景分两种：
  1. 如果消费者本地内存已经缓存了之前拉取到、还没消费完的记录，poll会直接从本地缓存读取数据返回，整个过程阻塞时长几乎为0，完全不会触发100ms的等待逻辑
  2. 如果消费者本地没有待消费的缓存数据，需要向Kafka broker发起远程拉取请求时，100ms才会作为最长等待时间生效：等到数据就立刻返回，等满100ms还没拿到数据就返回空的ConsumerRecords集合。

补充实践提示：这个超时值不建议设置过小（比如设为0），否则poll会只读取本地缓存后立刻返回，不会等待服务端响应，容易出现大量空轮询浪费CPU；也不建议设置过大，否则可能导致消费者长时间阻塞在poll逻辑中，无法按时发送心跳触发消费组重平衡。

内容的提问来源于stack exchange，提问作者Ankit Sahay