Hi Matthias,
I solved the problem with specifying the serders and reading source as
KStream instead of KTable. So, instead of
KTable source = builder.table("topic1");
I added:
KStream source =
builder.stream(longSerde,stringSerde,"topic1");
Thanks
-Adrienne
On Sun,
Can you show the full stack trace?
How do you ingest the date into the topic? I also think, you should read
the topic as KStream (instead 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)
-Ma
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 source = builder.t
