conduktor.io ↗

KIP-479 — Add StreamJoined config object to Join

Accepted Kafka 2.4 Streams

Adds a StreamJoined config object to KStream join operations, allowing users to specify custom SerDes, custom state store suppliers, and named repartition topics for both sides of a stream-stream join. Previously there was no unified way to configure the two windowed state stores backing a stream join, and SerDes had to be inferred or set globally.

Details

AuthorBill Bejeck
StatusAccepted
Kafka Version2.4
JIRAKAFKA-8558
WikiView on Apache Wiki
Created2019-06-18
Last Modified2019-09-25
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.