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

Reply via email to