Raghu Angadi created BEAM-777: --------------------------------- Summary: KafkaIO Test should handle reader.start() better Key: BEAM-777 URL: https://issues.apache.org/jira/browse/BEAM-777 Project: Beam Issue Type: Bug Components: sdk-java-extensions Reporter: Raghu Angadi Assignee: Raghu Angadi Priority: Minor
KafkaIOTest currently expects reader.start() to return true. It can return false as well. It should handle it better. -- This message was sent by Atlassian JIRA (v6.3.4#6332)