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)
