[jira] [Commented] (KAFKA-7406) Naming Join and Grouping Repartition Topics

["ASF GitHub Bot (JIRA)" <ji...@apache.org>]

    [ https://issues.apache.org/jira/browse/KAFKA-7406?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16631334#comment-16631334 ] 

ASF GitHub Bot commented on KAFKA-7406:
---------------------------------------

bbejeck opened a new pull request #5709: KAFKA-7406: Name join group repartition topics
URL: https://github.com/apache/kafka/pull/5709
 
 
   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)
   

----------------------------------------------------------------
This is an automated message from the Apache Git Service.
To respond to the message, please log on GitHub and use the
URL above to go to the specific comment.
 
For queries about this service, please contact Infrastructure at:
users@infra.apache.org


> Naming Join and Grouping Repartition Topics
> -------------------------------------------
>
>                 Key: KAFKA-7406
>                 URL: https://issues.apache.org/jira/browse/KAFKA-7406
>             Project: Kafka
>          Issue Type: Improvement
>          Components: streams
>            Reporter: Bill Bejeck
>            Assignee: Bill Bejeck
>            Priority: Major
>              Labels: needs-kip
>             Fix For: 2.1.0
>
>
> To help make Streams compatible with topology changes, we will need to give users the ability to name some operators so after adjusting the topology a rolling upgrade is possible.  
> This Jira is the first in this effort to allow for giving operators deterministic names.



--
This message was sent by Atlassian JIRA
(v7.6.3#76005)