conduktor.io ↗

KIP-819 — Merge multiple KStreams in one operation

Discussion Streams

Adds `KStream.merge(Collection<KStream>)` overloads so multiple streams can be merged in a single DSL call instead of chaining repeated binary `merge()` calls. Merging N streams via repeated binary merges creates N-1 merge nodes in the topology graph, complicating debugging and monitoring.

Details

AuthorNicholas Telford
StatusDiscussion
JIRAKAFKA-13633
WikiView on Apache Wiki
Created2022-01-31
Last Modified2022-01-31
Explore how this KIP affects the Kafka protocol in the Protocol Explorer, or see the full KIP database.