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

• Type: New Feature
• Status: Resolved
• Priority: Major
• Resolution: Fixed
• Fix Version/s: 1.0.0
• Component/s: streams
• Assignee: Damian Guy
• Reporter: Damian Guy
• Created: 26/Jul/17 15:20
• Updated: 01/Mar/19 22:41
• Resolved: 04/Oct/17 04:37

Issue Links

• contains: KAFKA-4281 Should be able to forward aggregation values immediately
• is duplicated by: KAFKA-5254 rethink KTable API overloads
• links to: GitHub Pull Request #4009
• mentioned in: Page Loading...

Sub-Tasks

• Provide a simple way for custom storage engines to use streams wrapped stores (KIP-182): Resolved
• Add new api methods to KStream: Resolved
• Add new API methods to KTable: Resolved
• Add new API methods to KGroupedStream: Resolved
• Add new API methods to KGroupedTable: Resolved
• Refactor KeyValueStore hierarchy so that MeteredKeyValueStore is the outermost store: Resolved
• Refactor WindowStore hierarchy so that Metered Store is the outermost store: Resolved
• Refactor SessionStore hierarchy: Resolved
• Add Printed class and KStream#print(Printed): Resolved
• Add Produced class and new to and through overloads to KStream: Resolved
• Add Serialized class and KStream groupBy and groupByKey overloads: Resolved
• Add Joined class and relevant KStream join overloads: Resolved
• Add Consumed class and overloads to StreamBuilder: Resolved
• Add groupBy(KeyValueMapper, Serialized) to KTable: Resolved
• Add filter, filterNot, mapValues and Materialized to KTable: Resolved
• Add WindowedKStream interface and implemenation: Resolved
• Add Materialized overloads to StreamBuilder: Resolved
• Add Materialized overloads to WindowedKStream: Resolved
• Add SessionWindowedKStream: Resolved
• Deprecate KTable#to and KTable#through: Resolved