Bulk Operation

KAFKA-5651 Deprecate KTable#to and KTable#through

KAFKA-5651 Add SessionWindowedKStream

KAFKA-5651 Add Materialized overloads to WindowedKStream

KAFKA-5651 Add Materialized overloads to StreamBuilder

KAFKA-5651 Add WindowedKStream interface and implemenation

KAFKA-5651 Add filter, filterNot, mapValues and Materialized to KTable

KAFKA-5651 Add groupBy(KeyValueMapper, Serialized) to KTable

KAFKA-5651 Add Consumed class and overloads to StreamBuilder

KAFKA-5651 Add Joined class and relevant KStream join overloads

KAFKA-5651 Add Serialized class and KStream groupBy and groupByKey overloads

KAFKA-5651 Add Produced class and new to and through overloads to KStream

KAFKA-5651 Add Printed class and KStream#print(Printed)

KAFKA-5651 Refactor SessionStore hierarchy

KAFKA-5651 Refactor WindowStore hierarchy so that Metered Store is the outermost store

KAFKA-5651 Refactor KeyValueStore hierarchy so that MeteredKeyValueStore is the outermost store

KAFKA-5651 Add new API methods to KGroupedTable

KAFKA-5651 Add new API methods to KGroupedStream

KAFKA-5651 Add new API methods to KTable

KAFKA-5651 Add new api methods to KStream

KAFKA-5651 Provide a simple way for custom storage engines to use streams wrapped stores (KIP-182)