From 74d396d131dbc1bbbb4e69f3caa1c9031a6d9981 Mon Sep 17 00:00:00 2001
From: Damian Guy <damian.guy@gmail.com>
Date: Wed, 27 Apr 2016 08:08:51 +0100
Subject: [PATCH] fix npe in KStreamImpl.to(..)

---
 .../kafka/streams/kstream/internals/KStreamImplTest.java   | 7 +++++++
 1 file changed, 7 insertions(+)

diff --git a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java
index b5c3d47a80b..aa54298efe7 100644
--- a/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java
+++ b/streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java
@@ -133,4 +133,11 @@ public class KStreamImplTest {
             1, // process
             builder.build("X", null).processors().size());
     }
+
+    @Test
+    public void testToWithNullValueSerdeDoesntNPE() {
+        final KStreamBuilder builder = new KStreamBuilder();
+        final KStream<String, String> inputStream = builder.stream(stringSerde, stringSerde, "input");
+        inputStream.to(stringSerde,null,"output");
+    }
 }