This PR has the changes required to implement KIP-372. 1. Name repartition topics for Joins 2. Name repartition topics for Grouping operations 3. For optimizations where repartition nodes are reduced or merged the topic name of the **_first_** repartition node to be merged is used as the topic name for the new optimized repartition node.
I've added tests for the following: 1. Verify that named repartition topics stay unchanged when topology changes. 2. Verify that user-specified repartition topic names are used over Streams generated names. 2. Verify that when optimization occurs, the new optimized repartition topic is the same name as the **_first_** replaced/merged repartition node. 3. The existing tests validate that when names for repartition topics are not provided the Streams generated names are used. ### Committer Checklist (excluded from commit message) - [ ] Verify design and implementation - [ ] Verify test coverage and CI build status - [ ] Verify documentation (including upgrade notes) [ Full content available at: https://github.com/apache/kafka/pull/5709 ] This message was relayed via gitbox.apache.org for [email protected]
