According to the documentation the NonResponsiveConsumerEvent should be emitted "when a consumer is not responding to the poll".
I'm using the following configuration:
- I have a single Kafka Listener that listens to a topic without any parallelism.
- The listener publishes in a syncronous way messages to another topic, waiting for ACKs after each send. (The duration of this process may vary, but I expect it to remain under 1 minute in total)
The issue I'm facing is that despite modifications to spring.kafka.listener.monitorInterval
and spring.kafka.listener.pollTimeout
, I still get NonResponsiveConsumerEvent
within 19 to 45 seconds.
I have set the pollTimeout to 5 minutes. Based on Spring Kafka here with a value of 5 minutes, and the default noPollThreshold to 3, I was expecting the event to be emitted after approximately 300 seconds. However, it still arrives within the same 19 to 45 second window.
Am I missing any conditions that could be emitting NonResponsiveConsumerEvent
?
Thanks!
发布者:admin,转转请注明出处:http://www.yc00.com/questions/1745167988a4614749.html
评论列表(0条)