conduktor.io ↗

KIP-862 — Self-join optimization for stream-stream joins

Accepted Kafka 3.8 Streams

Optimizes KStream-KStream inner self-joins (where both sides read from the same topic) to use a single state store instead of two identical stores. Self-joins in Kafka Streams were treated as regular joins, creating two stores that always contained identical data, doubling state storage and write amplification unnecessarily.

Details

AuthorVicky Papavasileiou
StatusAccepted
Kafka Version3.8
JIRAKAFKA-14209
WikiView on Apache Wiki
Created2022-07-29
Last Modified2022-09-21
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.