文章目錄

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

---

官方說明

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

選擇對應(yīng)的版本，我這里選的是 2.4.X

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

選擇

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

查找 max.poll.interval.ms

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

啥意思？

如果兩次poll操作間隔超過了這個(gè)時(shí)間，broker就會認(rèn)為這個(gè)consumer處理能力太弱，會將其踢出消費(fèi)組，將分區(qū)分配給別的consumer消費(fèi) ，觸發(fā)rebalance 。

如果你的消費(fèi)者節(jié)點(diǎn)總是在重啟完不久就不消費(fèi)了，可以考慮檢查改配置項(xiàng)或者優(yōu)化你的消費(fèi)者的消費(fèi)速度等等

---

配置

原生API

properties.put(ConsumerConfig.MAX_POLL_INTERVAL_MS_CONFIG, 10000);

---

Spring Kafka

根據(jù)@KafkaListener的配置

ConsumerConfig中支持的屬性，沒有顯式聲明的 都可以通過這個(gè)properties來進(jìn)行修改

舉個(gè)例子

consumer:auto-offset-reset: earliest # 設(shè)置消費(fèi)者分組最初的消費(fèi)進(jìn)度為 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

---

測試

我們隨手搭建一個(gè)Spring Boot的工程來測試下，這個(gè)配置項(xiàng)是否生效吧

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

啟動

可見已生效

總結(jié)

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

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。