root
/
kafka
mirror of https://github.com/apache/kafka.git
1
0
Fork 0
Code Issues Actions 4 Packages Projects Releases Wiki Activity

fix npe in KStreamImpl.to(..)

This commit is contained in:
Damian Guy 2016-04-27 08:08:51 +01:00
parent 33d745e2dc
commit 74d396d131
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
streams/src/test/java/org/apache/kafka/streams/kstream/internals/KStreamImplTest.java
View File

@ -133,4 +133,11 @@ public class KStreamImplTest {
1, // process 1, // process
builder.build("X", null).processors().size()); 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");
}
} }