[jira] [Created] (BEAM-2704) KafkaIO: NPE without key serializer set

2017-07-31 Thread Chris Pettitt (JIRA)
Chris Pettitt created BEAM-2704: --- Summary: KafkaIO: NPE without key serializer set Key: BEAM-2704 URL: https://issues.apache.org/jira/browse/BEAM-2704 Project: Beam Issue Type: Bug Co

[jira] [Created] (BEAM-2703) KafkaIO: watermark outside the bounds of BoundedWindow

2017-07-31 Thread Chris Pettitt (JIRA)
Chris Pettitt created BEAM-2703: --- Summary: KafkaIO: watermark outside the bounds of BoundedWindow Key: BEAM-2703 URL: https://issues.apache.org/jira/browse/BEAM-2703 Project: Beam Issue Type: B