conduktor.io ↗

KIP-292 — Add transformValues() method to KTable

Accepted Kafka 2.0 Streams

Adds transformValues() methods to the KTable interface in Kafka Streams DSL, allowing stateful, per-task value transformation with access to state stores and the full ValueTransformerWithKey lifecycle (init/close). The KTable interface previously only had mapValues(), which is stateless, thread-unsafe across tasks, and lacks state store access.

Details

AuthorAndrew Coates
StatusAccepted
Kafka Version2.0
JIRAKAFKA-6849
WikiView on Apache Wiki
Created2018-05-02
Last Modified2018-05-14
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.