Kafka
  1. Kafka
  2. KAFKA-602

A ConsumerConnector that never receives messages does not shutdown cleanly

    Details

    • Type: Bug Bug
    • Status: Open
    • Priority: Major Major
    • Resolution: Unresolved
    • Affects Version/s: 0.8.1
    • Fix Version/s: None
    • Component/s: None
    • Labels:
      None

      Description

      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

        Activity

        Jason Rosenberg created issue -
        Hide
        Jason Rosenberg added a comment -

        This is still an issue in 0.8 branch, as well.

        Show
        Jason Rosenberg added a comment - This is still an issue in 0.8 branch, as well.

          People

          • Assignee:
            Unassigned
            Reporter:
            Jason Rosenberg
          • Votes:
            0 Vote for this issue
            Watchers:
            3 Start watching this issue

            Dates

            • Created:
              Updated:

              Development