You are viewing a plain text version of this content. The canonical link for it is here.
Posted to dev@kafka.apache.org by "Jason Rosenberg (JIRA)" <ji...@apache.org> on 2012/11/07 17:07:12 UTC
[jira] [Created] (KAFKA-602) A ConsumerConnector that never
receives messages does not shutdown cleanly
Jason Rosenberg created KAFKA-602:
-------------------------------------
Summary: A ConsumerConnector that never receives messages does not shutdown cleanly
Key: KAFKA-602
URL: https://issues.apache.org/jira/browse/KAFKA-602
Project: Kafka
Issue Type: Bug
Affects Versions: 0.8.1
Reporter: Jason Rosenberg
Working with the latest trunk version (last commit was on 10/9/2012).
If I create a consumer connector, and create some KafkaStreams using a TopicFilter, but then never send any messages, and then call shutdown on the connector, the KafkaStreams never get notified of the shutdown.
Looking at ZookeeperConsumerConnector, in the method 'sendShutdownToAllQueues', It appears the current implementation is dependent on receiving at least 1 message with a topic, before initializing the list of topicThreadIdAndQueues, to send the shutdownCommand to.
Jason
--
This message is automatically generated by JIRA.
If you think it was sent incorrectly, please contact your JIRA administrators
For more information on JIRA, see: http://www.atlassian.com/software/jira