conduktor.io ↗

KIP-923 — Add A Grace Period to Stream Table Join

Accepted Kafka 3.7 Streams

Adds a gracePeriod parameter to Joined to buffer stream-side records in a stream-table join, allowing them to match the correct versioned table entry rather than the latest value at arrival time. Without buffering, stream records that arrive slightly before a table update join with the previous version, producing incorrect results even when a versioned table is used.

Details

AuthorWalker Carlson
StatusAccepted
Kafka Version3.7
JIRAKAFKA-14936
WikiView on Apache Wiki
Created2023-04-25
Last Modified2023-06-06
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.