[KAFKA-8558] KIP-479 - Add StreamJoined Overload to KStream#Join

• Type: Improvement
• Status: Resolved
• Priority: Blocker
• Resolution: Fixed
• Fix Version/s: 2.4.0
• Component/s: streams
• Labels: kip
• Assignee: Bill Bejeck
• Reporter: Bill Bejeck
• Created: 18/Jun/19 21:07
• Updated: 31/Oct/19 17:41
• Resolved: 03/Oct/19 03:32

Description

To prevent a topology incompatibility with the release of 2.4 and the naming of Join operations we'll add an overloaded KStream#join method accepting a Materialized parameter. This will allow users to explicitly name state stores created by Kafka Streams in the join operation.

The overloads will apply to all flavors of KStream#join (inner, left, and right). 

KIP-479: https://cwiki.apache.org/confluence/display/KAFKA/KIP-479%3A+Add+StreamJoined+config+object+to+Join

Issue Links

• contains: KAFKA-4729 Stores for kstream-kstream join cannot be in-memory
• Parent Feature: KAFKA-9126 Extend `StreamJoined` to allow more store configs
• links to: GitHub Pull Request #7285
• mentioned in: Page Loading...