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

fix npe in KStreamImpl.to(..)

This commit is contained in:
Damian Guy 2016-04-27 08:11:15 +01:00
parent 74d396d131
commit 07ce589429
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -138,6 +138,6 @@ public class KStreamImplTest {
public void testToWithNullValueSerdeDoesntNPE() {
final KStreamBuilder builder = new KStreamBuilder();
final KStream<String, String> inputStream = builder.stream(stringSerde, stringSerde, "input");
inputStream.to(stringSerde,null,"output");
inputStream.to(stringSerde, null, "output");
}
}