conduktor.io ↗

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

AuthorBoyang Chen
StatusAccepted
JIRAKAFKA-6840
WikiView on Apache Wiki
Created2018-05-11
Last Modified2019-05-17
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.