Apache Kafka-max.poll.interval.ms参数含义说明

小小工匠

发布于 2021-08-17 16:43:33

5.6K0

文章被收录于专栏：小工匠聊架构小工匠聊架构

官方说明

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 # 设置消费者分组最初的消费进度为 earliest
      key-deserializer: org.apache.kafka.common.serialization.StringDeserializer
      value-deserializer: org.springframework.kafka.support.serializer.JsonDeserializer
      properties:
        max:
          poll:
            interval:
              ms: 600000    # 10分钟 
        spring:
          json:
            trusted:
              packages: com.artisan.springkafka.domain

测试

我们随手搭建一个Spring Boot的工程来测试下，这个配置项是否生效吧

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

启动

可见已生效

本文参与腾讯云自媒体同步曝光计划，分享自作者个人站点/博客。

原始发表：2021/02/23 ，如有侵权请联系 cloudcommunity@tencent.com 删除

https

本文分享自作者个人站点/博客前往查看

如有侵权，请联系 cloudcommunity@tencent.com 删除。

本文参与腾讯云自媒体同步曝光计划，欢迎热爱写作的你一起参与！

登录后参与评论

0 条评论

热度

Apache Kafka-max.poll.interval.ms参数含义说明

Apache Kafka-max.poll.interval.ms参数含义说明

官方说明

配置

原生API

Spring Kafka

测试

社区

活动

圈层

关于

腾讯云开发者

热门产品

热门推荐

更多推荐