Search code examples
javaapache-kafkaspring-kafka

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


I need to increase max.poll.interval.ms default value of 300000 to a greater value, due to. timeout exceptions.

However I am unable to find the property (autocomplete) in application.properties to override it. Am I missing something out? Or I'm just using an old version of Spring Kafka (2.1.10)

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

Solution

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

    It worked