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
Attachments
Issue Links
- contains
-
KAFKA-4729 Stores for kstream-kstream join cannot be in-memory
- Resolved
- Parent Feature
-
KAFKA-9126 Extend `StreamJoined` to allow more store configs
- Resolved
- links to
- mentioned in
Bill, where are we with fixing this? Also, if I understand correctly, as trunk stands today, if you upgrade from versions < 2.3 to trunk, and if you name your join node, you will not reuse the join state store since the name will have changed?