Package com.bakdata.kafka.streams

Class RunningStreams.RunningStreamsBuilder

java.lang.Object

com.bakdata.kafka.streams.RunningStreams.RunningStreamsBuilder

Enclosing class:

RunningStreams

public static class RunningStreams.RunningStreamsBuilder
extends Object

Method Summary

Modifier and Type	Method	Description
RunningStreams	build()
RunningStreams.RunningStreamsBuilder	config(@NonNull StreamsConfigX config)
RunningStreams.RunningStreamsBuilder	streams(@NonNull org.apache.kafka.streams.KafkaStreams streams)
RunningStreams.RunningStreamsBuilder	topology(@NonNull org.apache.kafka.streams.Topology topology)
String	toString()

Methods inherited from class java.lang.Object

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

Method Details

config

public RunningStreams.RunningStreamsBuilder config(@NonNull
 @NonNull StreamsConfigX config)

Returns:

this.

topology

public RunningStreams.RunningStreamsBuilder topology(@NonNull
 @NonNull org.apache.kafka.streams.Topology topology)

Returns:

this.

streams

public RunningStreams.RunningStreamsBuilder streams(@NonNull
 @NonNull org.apache.kafka.streams.KafkaStreams streams)

Returns:

this.

build

public RunningStreams build()

toString

public String toString()

Overrides:

toString in class Object