Spring Kafka，重写 max.poll.interval.ms？

Question

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

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

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

Answer 1

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

Answer 2

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

有效

Answer 3

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

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

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

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

Spring Kafka，重写 max.poll.interval.ms？

Spring Kafka, overriding max.poll.interval.ms?

java

apache-kafka

spring-kafka