Apache Kafka-max.poll.interval.ms参数含义说明
生活随笔
收集整理的這篇文章主要介紹了
Apache Kafka-max.poll.interval.ms参数含义说明
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
文章目錄
- 官方說明
- 配置
- 原生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参数含义说明的全部內容,希望文章能夠幫你解決所遇到的問題。
- 上一篇: 深入理解分布式技术 - 顺序消费如何才能
- 下一篇: 深入理解分布式技术 - 消息幂等性如何