KIP-675 — Convert KTable to a KStream using the previous value
Discarded Streams
Adds a `toRecord()` operator to `KTable` that emits a `KStream` of records containing both the new value and the previous value, enabling stateless difference computations on table updates. Without this, computing deltas requires a manual `aggregate` with a custom accumulator holding the previous value, adding unnecessary state.
Details
| Author | Javier Freire Riobó |
| Status | Discarded |
| JIRA | KAFKA-10578 |
| Wiki | View on Apache Wiki |
| Created | 2020-10-05 |
| Last Modified | 2025-01-04 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.