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
| Author | Matthias J. Sax |
| Status | Discussion |
| JIRA | KAFKA-17178 |
| Wiki | View on Apache Wiki |
| Created | 2025-01-24 |
| Last Modified | 2025-11-27 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.