文章目錄

• 官方說明
• 配置
• • 原生API
  • Spring Kafka
• 測試

---

官方說明

https://kafka.apache.org/documentation/

選擇對應的版本，我這里選的是 2.4.X

https://kafka.apache.org/24/documentation.html

選擇

https://kafka.apache.org/24/documentation.html#consumerconfigs

查找 max.poll.interval.ms

讓我們來品一品官方的解讀

啥意思？

如果兩次poll操作間隔超過了這個時間，broker就會認為這個consumer處理能力太弱，會將其踢出消費組，將分區分配給別的consumer消費 ，觸發rebalance 。

如果你的消費者節點總是在重啟完不久就不消費了，可以考慮檢查改配置項或者優化你的消費者的消費速度等等

---

配置

原生API

properties.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, 10000);

---

Spring Kafka

根據@KafkaListener的配置

ConsumerConfig中支持的屬性，沒有顯式聲明的 都可以通過這個properties來進行修改

舉個例子

consumer:auto-offset-reset: earliest # 設置消費者分組最初的消費進度為 earliestkey-deserializer: org.apache.kafka.common.serialization.StringDeserializervalue-deserializer: org.springframework.kafka.support.serializer.JsonDeserializerproperties:max:poll:interval:ms: 600000 # 10分鐘 spring:json:trusted:packages: com.artisan.springkafka.domain

---

測試

我們隨手搭建一個Spring Boot的工程來測試下，這個配置項是否生效吧

properties:max:poll:interval:ms: 600000 # 10分鐘

啟動

可見已生效

總結

以上是生活随笔為你收集整理的Apache Kafka-max.poll.interval.ms参数含义说明的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。