Kirk True created KAFKA-17518:
---------------------------------
Summary: AsyncKafkaConsumer cannot reliably leave group when
closed with small timeout
Key: KAFKA-17518
URL: https://issues.apache.org/jira/browse/KAFKA-17518
Project: Kafka
Issue Type: Bug
Components: clients, consumer
Affects Versions: 3.9.0
Reporter: Kirk True
If {{close()}} is called with a short timeout (e.g. 0 ms), the process cannot
complete, leading to the consumer remaining in the consumer group.
On {{{}close(){}}}, the consumer attempts to unsubscribe and leave the consumer
group. This process requires hops back and forth between the application and
background threads to call the {{{}ConsumerRebalanceListener{}}}. Those hops
add a nonzero amount of time to the close step.
The events used to communicate between the application and background threads
are based on the timeout provided by the user. If the timeout is not
sufficient, the events will expire, and the process will be left incomplete.
--
This message was sent by Atlassian Jira
(v8.20.10#820010)
