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
| Author | Andrew Coates |
| Status | Accepted |
| Kafka Version | 2.0 |
| JIRA | KAFKA-6849 |
| Wiki | View on Apache Wiki |
| Created | 2018-05-02 |
| Last Modified | 2018-05-14 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.