...
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.
...