[jira] [Resolved] (KAFKA-4407) Java consumer does not always send LEAVE_GROUP request during shut down

["Igor (JIRA)" <ji...@apache.org>]

     [ https://issues.apache.org/jira/browse/KAFKA-4407?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel ]

Igor resolved KAFKA-4407.
-------------------------
    Resolution: Duplicate

Sorry for the duplicate, I'm closing this one. 

> Java consumer does not always send LEAVE_GROUP request during shut down
> -----------------------------------------------------------------------
>
>                 Key: KAFKA-4407
>                 URL: https://issues.apache.org/jira/browse/KAFKA-4407
>             Project: Kafka
>          Issue Type: Bug
>    Affects Versions: 0.10.1.0, 0.9.0.1
>            Reporter: Igor
>
> Normally, KafkaConsumer.close method sends LEAVE_GROUP request to the broker during shut down, since the method AbstractCoordinator.maybeLeaveGroup is called inside AbstractCoordinator.close method. However, maybeLeaveGroup does not actually care if request is sent, and since network client is closed nearly after the consumer coordinator during shut down, the request could be never sent under certain circumstances.
> As a result, Kafka broker will wait for session.timeout to remove the consumer from its group, and if the consumer reconnects within this time interval, it won't receive just came messages.
> If waiting for LEAVE_GROUP request is not a desired option, could its timeout be at least configured?



--
This message was sent by Atlassian JIRA
(v6.3.4#6332)