Raghu Angadi created BEAM-1837:
----------------------------------

             Summary: NPE in KafkaIO writer
                 Key: BEAM-1837
                 URL: https://issues.apache.org/jira/browse/BEAM-1837
             Project: Beam
          Issue Type: Bug
          Components: sdk-java-extensions
            Reporter: Raghu Angadi
            Assignee: Raghu Angadi


{{KafkaIO.writer()...values()}} does not require user to set key coder since 
the key always null. Validation passes, but it results in an NPE at runtime 
when the writer is tries to instantiates the producer.




--
This message was sent by Atlassian JIRA
(v6.3.15#6346)

Reply via email to