Re: Wordcount with reduce

2016-06-19 Thread Adrienne Kole
of KTable). > > What de-/serializer do you specify in props. (see > > http://docs.confluent.io/3.0.0/streams/developer-guide.html#streams-developer-guide-serdes > ) > > > -Matthias > > On 06/19/2016 03:06 PM, Adrienne Kole wrote: > > Hi, > > > >

Re: Wordcount with reduce

2016-06-19 Thread Matthias J. Sax
) -Matthias On 06/19/2016 03:06 PM, Adrienne Kole wrote: > Hi, > > I want to implement wordcount example with reduce function in KTable. > However, I get the error: > > Exception in thread "StreamThread-1" > org.apache.kafka.common.errors.SerializationExc

Wordcount with reduce

2016-06-19 Thread Adrienne Kole
Hi, I want to implement wordcount example with reduce function in KTable. However, I get the error: Exception in thread "StreamThread-1" org.apache.kafka.common.errors.SerializationException: Size of data received by LongDeserializer is not 8 Here is my code: KTable<