[
https://issues.apache.org/jira/browse/KAFKA-8611?page=com.atlassian.jira.plugin.system.issuetabpanels:comment-tabpanel&focusedCommentId=16875085#comment-16875085
]
Matthias J. Sax commented on KAFKA-8611:
----------------------------------------
Might be easiest to do all at once with one umbrella KIP. KIP-221 has broader
scope, so I might be easiest to discard KIP-485, and embed it in KIP-221 – if
fact, the idea to allow removing the name requirement was already considered in
the discussion of KIP-221.
> 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
> Priority: Minor
> Labels: needs-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)
