[
https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Matthias J. Sax updated KAFKA-8611:
-----------------------------------
Labels: kip (was: needs-kip)
> Make topic optional when using through() operations in DSL
> ----------------------------------------------------------
>
> Key: KAFKA-8611
> URL: https://issues.apache.org/jira/browse/KAFKA-8611
> Project: Kafka
> Issue Type: New Feature
> Components: streams
> Reporter: Levani Kokhreidze
> Assignee: Levani Kokhreidze
> Priority: Minor
> Labels: kip
>
> When using DSL in Kafka Streams, data re-partition happens only when
> key-changing operation is followed by stateful operation. On the other hand,
> in DSL, stateful computation can happen using _transform()_ operation as
> well. Problem with this approach is that, even if any upstream operation was
> key-changing before calling _transform()_, no auto-repartition is triggered.
> If repartitioning is required, a call to _through(String)_ should be
> performed before _transform()_. With the current implementation, burden of
> managing and creating the topic falls on user and introduces extra complexity
> of managing Kafka Streams application.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
