admin管理员组

文章数量:1415491

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!

本文标签: Spring Kafka NonResponsiveConsumerEvent occurs sooner then expectedStack Overflow