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

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

Attach filesAttach ScreenshotVotersWatch issueWatchersCreate sub-taskLinkCloneUpdate Comment AuthorReplace String in CommentUpdate Comment VisibilityDelete Comments
    XMLWordPrintableJSON

    Details

    • Type: New Feature
    • Status: Resolved
    • Priority: Major
    • Resolution: Fixed
    • Affects Version/s: None
    • Fix Version/s: 1.0.0
    • Component/s: streams
    • Labels:
      None

      Attachments

      Issue Links

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

        Activity

          People

          • Assignee:
            damianguy Damian Guy
            Reporter:
            damianguy Damian Guy

            Dates

            • Created:
              Updated:
              Resolved:

              Issue deployment