You are viewing a plain text version of this content. The canonical link for it is here.

Posted to dev@kafka.apache.org by "Vincent Rischmann (JIRA)" <ji...@apache.org> on 2013/12/11 20:07:07 UTC

[jira] [Created] (KAFKA-1179) createMessageStreams() in javaapi.ZookeeperConsumerConnector does not throw

Vincent Rischmann created KAFKA-1179:
----------------------------------------

             Summary: createMessageStreams() in javaapi.ZookeeperConsumerConnector does not throw
                 Key: KAFKA-1179
                 URL: https://issues.apache.org/jira/browse/KAFKA-1179
             Project: Kafka
          Issue Type: Bug
          Components: consumer
    Affects Versions: 0.8.0
            Reporter: Vincent Rischmann
            Assignee: Neha Narkhede


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.



--
This message was sent by Atlassian JIRA
(v6.1.4#6159)