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

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

Сработало

Answer 2

Вы можете использовать потребительский API, чтобы установить время ожидания. И настройте это время ожидания в файле свойств. Потребительский API предоставляет следующий способ установки продолжительности опроса.

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

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

Потребитель предоставляет различные типы аргументов для метода опроса. Вы можете использовать в соответствии с вашими требованиями.

Answer 3

Есть API , его нужно выставлять вручную. Прочтите из файла свойств и установите его.