Page History

...

The overloaded parameterless alternative `splitsplit()` is also available.

2. KBranchedStream has the following methods:

• KBranchedStream branch(Predicate<K,V> predicate, Branched<K,V> branched) -- creates a branch for messages that match the predicate and returns `this` this in order to facilitate method chaining.
• Map<String, KStream> defaultBranch(Branched<K,V> branched) -- creates a default branch (for messages not intercepted by other branches) and returns the dictionary of named KStreams.
• Map<String, KStream> noDefaultBranch() -- returns the dictionary of named KStreams.

...