XMLWordPrintableJSON

Details

    • Sub-task
    • Status: Resolved
    • Major
    • Resolution: Resolved
    • None
    • 0.10.1.0
    • streams

    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

          Activity

            People

              damianguy Damian Guy
              mjsax Matthias J. Sax
              Votes:
              0 Vote for this issue
              Watchers:
              3 Start watching this issue

              Dates

                Created:
                Updated:
                Resolved: