[
https://issues.apache.org/jira/browse/KAFKA-3822?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15353497#comment-15353497
]
Ashish K Singh commented on KAFKA-3822:
---------------------------------------
[~hachikuji] while working out a POC, I thought more about the options we have.
Wanted to bounce it off you, before opening it up to larger audience via KIP.
* *Adding timeout to close in {{KafkaConsumer.close()}}* In {{KafkaProducer}}
adding timeout to close was required as while closing it has incomplete
requests that are taken care of and timeout specifies max time user would want
to wait for those requests to complete. However, in {{KafkaConsumer}} we only
wait for various underlying {{closable}} components like,
{{ConsumerCoordinator}}, etc, to close.
* *Adding {{max.block.ms}} config to {{ConsumerConfig}}* this config can be
accessed by ConsumerCoordinator while doing synchronous waiting, like during
{{ensureCoordinatorReady}}.
[Here|https://github.com/SinghAsDev/kafka/commit/3469a9fd7f9b9310652845f0b853fe3eda07b8c4]
is a small POC.
Thoughts?
> Kafka Consumer close() hangs indefinitely if Kafka Broker shutdown while
> connected
> ----------------------------------------------------------------------------------
>
> Key: KAFKA-3822
> URL: https://issues.apache.org/jira/browse/KAFKA-3822
> Project: Kafka
> Issue Type: Bug
> Components: clients
> Affects Versions: 0.9.0.1, 0.10.0.0
> Environment: x86 Red Hat 6 (1 broker running zookeeper locally,
> client running on a separate server)
> Reporter: Alexander Cook
> Assignee: Ashish K Singh
>
> I am using the KafkaConsumer java client to consume messages. My application
> shuts down smoothly if I am connected to a Kafka broker, or if I never
> succeed at connecting to a Kafka broker, but if the broker is shut down while
> my consumer is connected to it, consumer.close() hangs indefinitely.
> Here is how I reproduce it:
> 1. Start 0.9.0.1 Kafka Broker
> 2. Start consumer application and consume messages
> 3. Stop 0.9.0.1 Kafka Broker (ctrl-c or stop script)
> 4. Try to stop application...hangs at consumer.close() indefinitely.
> I also see this same behavior using 0.10 broker and client.
> This is my first bug reported to Kafka, so please let me know if I should be
> following a different format. Thanks!
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
