You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Igor (JIRA)" <ji...@apache.org> on 2016/11/14 15:40:59 UTC

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

Igor created KAFKA-4407:
---------------------------

             Summary: 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.9.0.1, 0.10.1.0
            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)