Uploaded image for project: 'Kafka'
  1. Kafka
  2. KAFKA-5651

KIP-182: Reduce Streams DSL overloads and allow easier use of custom storage engines

    XMLWordPrintableJSON

Details

    • New Feature
    • Status: Resolved
    • Major
    • Resolution: Fixed
    • None
    • 1.0.0
    • streams
    • None

    Attachments

      Issue Links

        contains

        Bug - A problem which impairs or prevents the functions of the product. KAFKA-4281 Should be able to forward aggregation values immediately

        • Major - Major loss of function.
        • Resolved
        is duplicated by

        Improvement - An improvement or enhancement to an existing feature or task. KAFKA-5254 rethink KTable API overloads

        • Major - Major loss of function.
        • Resolved
        links to

        Web Link GitHub Pull Request #4009

        mentioned in

        Page Loading...

        1.
        		 Provide a simple way for custom storage engines to use streams wrapped stores (KIP-182) Sub-task Resolved Damian Guy
        2.
        		 Add new api methods to KStream Sub-task Resolved Damian Guy
        3.
        		 Add new API methods to KTable Sub-task Resolved Damian Guy
        4.
        		 Add new API methods to KGroupedStream Sub-task Resolved Damian Guy
        5.
        		 Add new API methods to KGroupedTable Sub-task Resolved Damian Guy
        6.
        		 Refactor KeyValueStore hierarchy so that MeteredKeyValueStore is the outermost store Sub-task Resolved Damian Guy
        7.
        		 Refactor WindowStore hierarchy so that Metered Store is the outermost store Sub-task Resolved Damian Guy
        8.
        		 Refactor SessionStore hierarchy Sub-task Resolved Damian Guy
        9.
        		 Add Printed class and KStream#print(Printed) Sub-task Resolved Damian Guy
        10.
        		 Add Produced class and new to and through overloads to KStream Sub-task Resolved Damian Guy
        11.
        		 Add Serialized class and KStream groupBy and groupByKey overloads Sub-task Resolved Damian Guy
        12.
        		 Add Joined class and relevant KStream join overloads Sub-task Resolved Damian Guy
        13.
        		 Add Consumed class and overloads to StreamBuilder Sub-task Resolved Damian Guy
        14.
        		 Add groupBy(KeyValueMapper, Serialized) to KTable Sub-task Resolved Damian Guy
        15.
        		 Add filter, filterNot, mapValues and Materialized to KTable Sub-task Resolved Damian Guy
        16.
        		 Add WindowedKStream interface and implemenation Sub-task Resolved Damian Guy
        17.
        		 Add Materialized overloads to StreamBuilder Sub-task Resolved Damian Guy
        18.
        		 Add Materialized overloads to WindowedKStream Sub-task Resolved Damian Guy
        19.
        		 Add SessionWindowedKStream Sub-task Resolved Damian Guy
        20.
        		 Deprecate KTable#to and KTable#through Sub-task Resolved Damian Guy

        Activity

          People

            damianguy Damian Guy
            damianguy Damian Guy
            Votes:
            0 Vote for this issue
            Watchers:
            5 Start watching this issue

            Dates

              Created:
              Updated:
              Resolved: