Guozhang Wang created KAFKA-6641:

             Summary: Consider auto repartitioning for Stream.transform() API
                 Key: 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

Reply via email to