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