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, KeyValueMapp
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,
KeyValueMapp
