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
| Author | Vicky Papavasileiou |
| Status | Accepted |
| Kafka Version | 3.8 |
| JIRA | KAFKA-14209 |
| Wiki | View on Apache Wiki |
| Created | 2022-07-29 |
| Last Modified | 2022-09-21 |
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.