kafka-dev mailing list archives

Site index · List index
Message view « Date » · « Thread »
Top « Date » · « Thread »
From "Jason Rosenberg (JIRA)" <j...@apache.org>
Subject [jira] [Created] (KAFKA-602) A ConsumerConnector that never receives messages does not shutdown cleanly
Date Wed, 07 Nov 2012 16:07:12 GMT
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

Mime
View raw message