[
https://issues.apache.org/jira/browse/KAFKA-3898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15347901#comment-15347901
]
Damian Guy commented on KAFKA-3898:
-----------------------------------
If the stream has been mapped or flatMapped it needs the Serdes passed along
otherwise it will fall back to the default which may or may not be correct and
you can end up with an exception like below:
[2016-06-13 09:52:15,515] ERROR Streams application error during processing in
thread [StreamThread-4]:
(org.apache.kafka.streams.processor.internals.StreamThread:225)
java.lang.ClassCastException: java.lang.Integer cannot be cast to [B
> KStream.leftJoin(...) is missing a Serde for thisVal. This can cause failures
> after mapValues etc
> -------------------------------------------------------------------------------------------------
>
> Key: KAFKA-3898
> URL: https://issues.apache.org/jira/browse/KAFKA-3898
> Project: Kafka
> Issue Type: Bug
> Components: streams
> Affects Versions: 0.10.0.0
> Reporter: Damian Guy
> Assignee: Damian Guy
> Fix For: 0.10.0.1
>
>
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
