[ https://issues.apache.org/jira/browse/KAFKA-17518?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]
Lianet Magrans resolved KAFKA-17518. ------------------------------------ Resolution: Fixed > 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 > Assignee: Kirk True > Priority: Major > Labels: consumer-threading-refactor, kip-848-client-support > Fix For: 4.0.0 > > > 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)