conduktor.io ↗

KIP-1128 — Replace KTable.transformValues with KTable.processValues and add new KStreams.process

Discussion Streams

Deprecates KTable.transformValues (still using the old Processor API) and replaces it with KTable.processValues using the new typed Processor API; also deprecates KStreams.processValues to fix a backward-incompatibility bug introduced in its implementation. The old Processor API classes could not be fully removed in Kafka 4.0 because KTable.transformValues still referenced them, and a bug in KStream.processValues made migration via the new API unsafe.

Details

AuthorMatthias J. Sax
StatusDiscussion
JIRAKAFKA-17178
WikiView on Apache Wiki
Created2025-01-24
Last Modified2025-11-27
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.