[
https://issues.apache.org/jira/browse/KAFKA-8558?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16921506#comment-16921506
]
ASF GitHub Bot commented on KAFKA-8558:
---------------------------------------
bbejeck commented on pull request #7285: KAFKA-8558: Add materialized to join
URL: https://github.com/apache/kafka/pull/7285
This PR adds `Materialized` to a `Streams` - `Streams` join, allowing to
separate the naming of the join state stores from the name of the join
processor. See [KIP-479 for more
details](https://cwiki.apache.org/confluence/display/KAFKA/KIP-479%3A+Add+Materialized+to+Join).
For testing some of the existing tests were updated and additional tests
added verifying the expected behavior.
### Committer Checklist (excluded from commit message)
- [ ] Verify design and implementation
- [ ] Verify test coverage and CI build status
- [ ] Verify documentation (including upgrade notes)
----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on to GitHub and use the
URL above to go to the specific comment.
For queries about this service, please contact Infrastructure at:
[email protected]
> KIP-479 - Add Materialized Overload to KStream#Join
> ----------------------------------------------------
>
> Key: KAFKA-8558
> URL: https://issues.apache.org/jira/browse/KAFKA-8558
> Project: Kafka
> Issue Type: Improvement
> Components: streams
> Reporter: Bill Bejeck
> Assignee: Bill Bejeck
> Priority: Blocker
> Labels: needs-kip
> Fix For: 2.4.0
>
>
> 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).
--
This message was sent by Atlassian Jira
(v8.3.2#803003)
