[X] I have searched issues to ensure it has not already been reported
Description
The consumer may become unresponsive if it exceeds the maximum polling interval and is then requested to stop.
Steps to reproduce
Create a new consumer.
Make sure to configure the consumer with a short maximum poll interval.
Create a scenario where the consumer takes more time than the configured maximum poll interval by adding an artificial delay.
Once the maximum poll interval has been exceeded, the partitions will be revoked and the consumer will be asked to stop. After that, the StopAsync() method will remain blocked indefinitely.
Expected behavior
The consumer must stop immediately when the partition is revoked due to exceeding the maximum poll interval.
Prerequisites
Description
The consumer may become unresponsive if it exceeds the maximum polling interval and is then requested to stop.
Steps to reproduce
Create a new consumer.
Make sure to configure the consumer with a short maximum poll interval.
Create a scenario where the consumer takes more time than the configured maximum poll interval by adding an artificial delay.
Once the maximum poll interval has been exceeded, the partitions will be revoked and the consumer will be asked to stop. After that, the StopAsync() method will remain blocked indefinitely.
Expected behavior
The consumer must stop immediately when the partition is revoked due to exceeding the maximum poll interval.
Actual behavior
The consumer gets stuck and never stops.
KafkaFlow version
v3.0.1