Spring Kafka，覆盖 max.poll.interval.ms？答案

【问题标题】：Spring Kafka, overriding max.poll.interval.ms?Spring Kafka，覆盖 max.poll.interval.ms？
【发布时间】：2020-05-07 15:23:36
【问题描述】：

我需要将 max.poll.interval.ms 默认值 300000 增加到更大的值，因为。超时异常。

但是我无法在 application.properties 中找到属性（自动完成）来覆盖它。我错过了什么吗？或者我只是在使用旧版本的 Spring Kafka (2.1.10)

max.poll.interval.ms = 300000
max.poll.records     = 500

【问题讨论】：

标签： java apache-kafka spring-kafka

【解决方案1】：

spring.kafka.consumer.properties.max.poll.interval.ms=20000000

成功了

【讨论】：

【解决方案2】：

有一个API，你必须手动设置它。从属性文件中读取并设置它。

【讨论】：

【解决方案3】：

您可以使用消费者 API 来设置超时。并在您的属性文件中配置该超时。 Consumer API 提供以下方式来设置轮询持续时间。

    @Value("${pollDuration}")
    private Long pollDuration;   //read from property file

    ConsumerRecords<String, String> records = consumer.poll(Duration.ofMillis(pollDuration));

Consumer 为 poll 方法提供了不同类型的参数。您可以根据自己的要求使用。

【讨论】：