[
https://issues.apache.org/jira/browse/KAFKA-3822?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Alexander Cook updated KAFKA-3822:
----------------------------------
Description:
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!
was:
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 am going to try this out on 0.10 to see if the same thing happens.
This is my first bug reported to Kafka, so please let me know if I should be
following a different format. Thanks!
> 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
> Environment: x86 Red Hat 6 (1 broker running zookeeper locally,
> client running on a separate server)
> Reporter: Alexander Cook
>
> 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)
