[
https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:all-tabpanel
]
Levani Kokhreidze updated KAFKA-8611:
-------------------------------------
Summary: Add KStream#repartition operation (was: Make topic optional when
using through() operations in DSL)
> Add KStream#repartition operation
> ---------------------------------
>
> 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.
> KIP-221:
> [https://cwiki.apache.org/confluence/display/KAFKA/KIP-221%3A+Enhance+KStream+with+Connecting+Topic+Creation+and+Repartition+Hint]
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
