KIP-418 — A method-chaining way to branch KStream

Accepted Kafka 2.8 Streams

Replaces KStream#branch(Predicate...) with a fluent split()/branch()/defaultBranch() API returning a named Map<String, KStream> instead of an array. Eliminates the impedance mismatch between Java generics and arrays, removes magic-number array indexing, and enables dynamic branch construction without unchecked casts.

Details