conduktor.io ↗

KIP-202 — Move merge() from StreamsBuilder to KStream

Accepted Kafka 1.0 Streams

Moves the merge(KStream) method from StreamsBuilder to the KStream interface itself, so two streams are merged via stream1.merge(stream2) instead of builder.merge(stream1, stream2). The original placement on StreamsBuilder was unintuitive, as merging is a stream-to-stream operation that should be expressed on the KStream object.

Details

AuthorRichard Yu
StatusAccepted
Kafka Version1.0
JIRAKAFKA-5765
WikiView on Apache Wiki
Created2017-09-17
Last Modified2017-10-29
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.