[
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)
