KIP-300 — Add Windowed KTable API in StreamsBuilder
Accepted Streams
Adds StreamsBuilder#table() overloads that materialize a windowed changelog topic into a windowed KTable backed by either a persistent or in-memory windowed state store. Kafka Streams had no DSL method to consume a pre-existing windowed changelog topic (e.g., output of another Streams app) directly into a local windowed store for downstream join or query operations.
Details
| Author | Boyang Chen |
| Status | Accepted |
| JIRA | KAFKA-6840 |
| Wiki | View on Apache Wiki |
| Created | 2018-05-11 |
| Last Modified | 2019-05-17 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.