Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-1179

createMessageStreams() in javaapi.ZookeeperConsumerConnector does not throw

    Details

    • Type: Bug
    • Status: Closed
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: 0.8.0
    • Fix Version/s: 0.8.2.0
    • Component/s: consumer
    • Labels:

      Description

      In kafka.consumer.javaapi.ZookeeperConsumerConnector.scala, the createMessageStreams() directly calls underlying.consume() (line 80)
      In kafka.consumer.ZookeeperConsumerConnector.scala, the createMessageStreams() throws an exception if it has been called more than once (line 133).

      The javaapi should throw if it is called more than once, just like the scala api.

        Attachments

        1. KAFKA-1179-v1.patch
          3 kB
          Sriharsha Chintalapani
        2. KAFKA-1179.patch
          3 kB
          Sriharsha Chintalapani
        3. KAFKA-1179_2014-05-14_14:40:11.patch
          14 kB
          Sriharsha Chintalapani
        4. KAFKA-1179_2014-05-14_14:19:11.patch
          14 kB
          Sriharsha Chintalapani

          Activity

            People

            • Assignee:
              sriharsha Sriharsha Chintalapani
              Reporter:
              vrischmann Vincent Rischmann
            • Votes:
              0 Vote for this issue
              Watchers:
              4 Start watching this issue

              Dates

              • Created:
                Updated:
                Resolved: