...
- future release Kafka 2.3:
- KIP-149: Enabling key access in ValueTransformer, ValueMapper, and ValueJoiner (partially implemented in v1.1)
- KIP-150 - Kafka-Streams Cogroup
- KIP-213 Support non-key joining in KTable
- KIP-258: Allow to Store Record Timestamps in RocksDB
- KIP-300: Add Windowed KTable API in StreamsBuilder
- KIP-307: Allow to define custom processor names with KStreams DSL
- KIP-313: Add KStream.flatTransform and KStream.flatTransformValues (partially implemented in v2.2)
- KIP-328: Ability to suppress updates for KTables (partially implemented in v2.1)
- KIP-428: Add in-memory window store
- upcoming release Kafka 2.2:
...
- KIP-116: Add State Store Checkpoint Interval Configuration
- KIP-132: Augment KStream.print to allow extra parameters in the printed string (duplicated by KIP-160)
- KIP-147: Add missing type parameters to StateStoreSupplier factories and KGroupedStream/Table methods (covered via KIP-182)
- KIP-165: Extend Interactive Queries for return latest update timestamp per key (covered via KIP-258)
- KIP 230: Name Windowing Joins (covered via KIP-372: Naming Repartition Topics for Joins and Grouping)
- KIP-262: Metadata should include number of state stores for task
- KIP-364: Remove implicit Materialized, Consumed and Produced (covered via KIP-365: Materialized, Serialized, Joined, Consumed and Produced with implicit Serde)
...