[
https://issues.apache.org/jira/browse/KAFKA-3898?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15347928#comment-15347928
]
Damian Guy commented on KAFKA-3898:
-----------------------------------
Turns out this is not an issue on 0.10.0 - my mistake. It was an issue on trunk
because we now do auto-repartitioning on map etc, so the Serdes need to be
passed along. However, on 0.10.0 this doesn't happen and developers are
expected to do:
{code}
streamOne.map((key,value) -> value).through(Serdes.Integer(),
Serdes.Integer(),"through-topic")
{code}
Closing
> 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)
