conduktor.io ↗

KIP-962 — Relax non-null key requirement in Kafka Streams

Accepted Kafka 3.7 Streams

Changes Kafka Streams left-join and outer-join operators (KStream-KStream, KStream-KTable, KStream-GlobalTable, KTable-KTable foreign-key) to no longer drop records with null keys, instead passing null to ValueJoiner for the absent side. The existing strict null-key rejection was inconsistent with the defined left/outer join semantics of retaining the record when no match is found.

Details

AuthorFlorin Akermann
StatusAccepted
Kafka Version3.7
JIRAKAFKA-12317
WikiView on Apache Wiki
Created2023-07-29
Last Modified2023-12-09
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.