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)
