Page History

...

• as(String name) -- sets the name of the branch (auto-generated by default, when split operation is named, then the names are index-suffixed).
• withwithFunction(Function<? super KStream<? super K, ? super KStream<K, V>, ? extends KStream<? extends K, ? extends KStream<K, V>> chain) — sets an operation with a given branch. By default, it is an s->s identity function. Can be complex, like s->s.mapValues...., a composition of functions etc.
• withwithConsumer(Consumer<? super KStream<? super K, ? super KStream<K, V>> chain) — sets a consumer for a given branch.
• withwithFunction(Function<? super KStream<? super K, ? super KStream<K, V>, ? extends KStream<? extends K, ? extends KStream<K, V>> chain, String name) — sets both an operation and a name.
• withwithConsumer(Consumer<? super KStream<? super K, ? super KStream<K, V>> chain, String name) — sets both a consumer and a name.

...

class Branched<K, V> implements Named<Branched<K,V>> {
    static Branched<K, V> as(String name);
    static Branched<K, V> withwithFunction(Function<? super KStream<? super K, ? superKStream<K, V>, ? extends KStream<? extends K, ? extendsKStream<K, V>> chain);
    static Branched<K, V> withwithConsumer(Consumer<? super KStream<? super K, ? super KStream<K, V>> chain);
    static Branched<K, V> withwithFunction(Function<? super KStream<? super K, ? superKStream<K, V>, ? extends KStream<? extends K, ? extends KStream<K, V>> chain, String name);
    static Branched<K, V> withwithConsumer(Consumer<? super KStream<? super K, ? superKStream<K, V>> chain, String name);
}

...