Package com.bakdata.kafka.streams.kstream

Class BranchedX<K,V>

java.lang.Object

com.bakdata.kafka.streams.kstream.BranchedX<K,V>

Type Parameters:

K - type of keys

V - type of values

public final class BranchedX<K,V>
extends Object

Extends the Branched interface by adding methods to simplify Serde configuration, error handling, and topic access

Method Summary

Modifier and Type	Method	Description
static <K, V> BranchedX<K,V>	as(String name)
protected final BranchedX<K,V>	modify(BiFunction<? super org.apache.kafka.streams.kstream.Branched<K,V>,? super StreamsContext,? extends org.apache.kafka.streams.kstream.Branched<K,V>> modifier)
protected final BranchedX<K,V>	modify(Function<? super org.apache.kafka.streams.kstream.Branched<K,V>,? extends org.apache.kafka.streams.kstream.Branched<K,V>> modifier)
protected BranchedX<K,V>	newInstance(Function<StreamsContext,org.apache.kafka.streams.kstream.Branched<K,V>> initializer)
static <K, V> BranchedX<K,V>	withConsumer(Consumer<? super KStreamX<K,V>> chain)
static <K, V> BranchedX<K,V>	withFunction(Function<? super KStreamX<K,V>,? extends org.apache.kafka.streams.kstream.KStream<K,V>> chain)
BranchedX<K,V>	withName(String name)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Method Details

withConsumer

public static <K,
V> BranchedX<K,V> withConsumer(Consumer<? super KStreamX<K,V>> chain)

See Also:

• Branched.withConsumer(Consumer)

withFunction

public static <K,
V> BranchedX<K,V> withFunction(Function<? super KStreamX<K,V>,? extends org.apache.kafka.streams.kstream.KStream<K,V>> chain)

See Also:

• Branched.withFunction(Function)

as

public static <K,
V> BranchedX<K,V> as(String name)

See Also:

• Branched.as(String)

withName

public BranchedX<K,V> withName(String name)

See Also:

• Branched.withName(String)

newInstance

protected BranchedX<K,V> newInstance(Function<StreamsContext,org.apache.kafka.streams.kstream.Branched<K,V>> initializer)

modify

protected final BranchedX<K,V> modify(BiFunction<? super org.apache.kafka.streams.kstream.Branched<K,V>,? super StreamsContext,? extends org.apache.kafka.streams.kstream.Branched<K,V>> modifier)

modify

protected final BranchedX<K,V> modify(Function<? super org.apache.kafka.streams.kstream.Branched<K,V>,? extends org.apache.kafka.streams.kstream.Branched<K,V>> modifier)