Guozhang Wang created KAFKA-6641:
------------------------------------
Summary: Consider auto repartitioning for Stream.transform() API
Key: KAFKA-6641
URL: https://issues.apache.org/jira/browse/KAFKA-6641
Project: Kafka
Issue Type: Improvement
Components: streams
Reporter: Guozhang Wang
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.
--
This message was sent by Atlassian JIRA
(v7.6.3#76005)
