[KAFKA-9976] Aggregates should reuse repartition nodes

• Type: Improvement
• Status: Resolved
• Priority: Major
• Resolution: Won't Fix
• Component/s: streams
• Labels: streams
• Assignee: Bill Bejeck
• Reporter: Bill Bejeck
• Created: 09/May/20 15:51
• Updated: 21/May/20 17:50
• Resolved: 21/May/20 17:50

Description

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.

Issue Links

• links to: GitHub Pull Request #8637