[
https://issues.apache.org/jira/browse/KAFKA-3745?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=15297733#comment-15297733
]
Greg Fodor commented on KAFKA-3745:
-----------------------------------
Yes, the join key needs to be added to the final joined record. I suppose like
you mention a nicer approach may be to just to emit the joined record with a
null in place of where the key will go, and then do a simple .map after the
join to fill in the key, this seems better than what I am doing now.
> Consider adding join key to ValueJoiner interface
> -------------------------------------------------
>
> Key: KAFKA-3745
> URL: https://issues.apache.org/jira/browse/KAFKA-3745
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Affects Versions: 0.10.0.0
> Reporter: Greg Fodor
> Priority: Minor
> Labels: api, newbie
>
> In working with Kafka Stream joining, it's sometimes the case that a join key
> is not actually present in the values of the joins themselves (if, for
> example, a previous transform generated an ephemeral join key.) In such
> cases, the actual key of the join is not available in the ValueJoiner
> implementation to be used to construct the final joined value. This can be
> worked around by explicitly threading the join key into the value if needed,
> but it seems like extending the interface to pass the join key along as well
> would be helpful.
--
This message was sent by Atlassian JIRA
(v6.3.4#6332)
