spring-kafka icon indicating copy to clipboard operation
spring-kafka copied to clipboard

Calling `.nack()` suspends consumer group rebalance

Open tkornai opened this issue 3 years ago • 11 comments

In what version(s) of Spring for Apache Kafka are you seeing this issue?

I tested the following versions, they all show the same behaviour:

2.3.13, 2.5.14, 2.6.3, 2.8.2

Describe the bug

After calling KafkaMessageListenerContainer.nack() if a consumer group rebalance is triggered then it won't finish until the nack() timeout has passed.

The extended CG rebalance prevents every member of the consumer group from progressing with message processing.

To Reproduce

Please follow the steps described in the sample repository: https://github.com/tkornai/nack-rebalance-demo

Expected behavior

Calling nack() must not delay subsequent consumer group rebalances.

Sample

A link to a GitHub repository with a minimal, reproducible, sample.

tkornai avatar Feb 23 '22 15:02 tkornai