Bill Bejeck created KAFKA-9976:
----------------------------------

             Summary: Aggregates should reuse repartition nodes
                 Key: KAFKA-9976
                 URL: https://issues.apache.org/jira/browse/KAFKA-9976
             Project: Kafka
          Issue Type: Improvement
          Components: streams
            Reporter: Bill Bejeck
            Assignee: Bill Bejeck


The `GroupedStreamAggregateBuilder` will re-use the repartition node if the 
user provides a name via `Grouped`, otherwise it will create a new repartition 
node.  The fix in KAFKA-9298 results in reusing the repartition node for 
KStream objects performing multiple joins, so the `KGroupedStream` should 
follow the same pattern and reuse the repartition node when a `KGroupedStream` 
needs repartitioning and performs multiple aggregates.



--
This message was sent by Atlassian Jira
(v8.3.4#803005)

Reply via email to