Re: Kafka Streams - Java StreamException - Serdes issue

Hi Bill, Thanks so much for your help but unfortunately i did not work, I had the same error trace. I found where the issue was: groupByKey, as described here So adding the *Grouped.wi

Re: Kafka Streams - Java StreamException - Serdes issue

Hi Gioacchino, If I'm understanding your topology correctly it looks like you are doing a reduce operation where the result is a double. For stateful operations, Kafka Streams uses persistent state stores for keeping track of the update stream. When using the KGroupedStream#reduce method, if you

Kafka Streams - Java StreamException - Serdes issue

Hi experts, I believe to understand there is the need to set the serde for the Double type after/in the map function for a re-partition task. I can't figure out where to specified. I've already tried to find the answer on documentation and article but I failed. The following code KStream