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

• 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: newbie usability
• Assignee: Harsha
• Reporter: Vincent Rischmann
• Created: 11/Dec/13 19:06
• Updated: 22/Jul/14 14:39
• Resolved: 16/May/14 00:36

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.