conduktor.io ↗

KIP-114 — KTable state stores and improved semantics

Accepted Kafka 1.0 Streams

Clarifies and formalizes KTable materialization semantics in Kafka Streams, introducing a Materialized class that allows users to explicitly name and configure state stores for any KTable operation, and making store creation optional for operations that do not require it. The existing API required providing a store name for aggregation KTables but silently ignored it for filter/map KTables, causing confusion and preventing Interactive Queries on derived tables.

Details

AuthorEno Thereska
StatusAccepted
Kafka Version1.0
JIRAKAFKA-5045
WikiView on Apache Wiki
Created2017-01-16
Last Modified2017-04-27
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.