[
https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-4601:
---
Fix Version/s: 2.1.0
> Avoid duplicated repartitioning in KStream DSL
> -
[
https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-4601:
-
Issue Type: Sub-task (was: Bug)
Parent: KAFKA-6034
> Avoid duplicated repartitioning in K
[
https://issues.apache.org/jira/browse/KAFKA-4601?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Guozhang Wang updated KAFKA-4601:
-
Description:
Consider the following DSL:
{code}
Stream source = builder.stream(Serdes.String(),