Description
Today with map / mapValues of Streams DSL, we will set a flag / not set a flag for the underlying topology builder; but for transform / transformValues, we do not make such marking choices. Maybe the topology builder can still make such flagging for transform() to indicate that since the key maybe changed, we should issue a repartition for the downstream stateful operators when necessary.
Attachments
Issue Links
- duplicates
-
KAFKA-7608 A Kafka Streams DSL transform or process call should potentially trigger a repartition
-
- Resolved
-
- Is contained by
-
KAFKA-3561 Auto create through topic for KStream aggregation and join
-
- Resolved
-