Hi Jeyhun, thanks for reporting! It got already fixed in trunk version.
https://issues.apache.org/jira/browse/KAFKA-3589 https://github.com/apache/kafka/pull/1246/files -Matthias On 06/19/2016 02:46 PM, Jeyhun Karimov wrote: > Hi community, > > When using, reduce(Reducer,Reducer, KeyValueMapper,String) function in > KTable, the NullPointerExeption is thrown. In specified function, below > call is made: > > return reduce(adder, subtractor, selector, null, null, name); > > and afterwards, in reduce(Reducer,Reducer, > KeyValueMapper,Serde,Serde,String) function, the exception is thrown while > creating ChangedSerializer. I think null checks should be added to escape > the exception. > > Jeyhun >
signature.asc
Description: OpenPGP digital signature
