Description
For KTable aggregations, it has a pattern of table.groupBy(...).aggregate(...), and the data is repartitioned in an inner topic based on the selected key in groupBy(...).
For KStream aggregations, though, it has a pattern of stream.selectKey(...).through(...).aggregateByKey(...). In other words, users need to manually use a topic to repartition data, and the syntax is a bit different with KTable as well.
Goal
To have similar APIs for aggregations of KStream and KTable
Attachments
Issue Links
- relates to
-
KAFKA-3561 Auto create through topic for KStream aggregation and join
-
- Resolved
-
- mentioned in
-
Page Loading...