conduktor.io ↗

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

AuthorJavier Freire Riobó
StatusDiscarded
JIRAKAFKA-10578
WikiView on Apache Wiki
Created2020-10-05
Last Modified2025-01-04
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.