Class KafkaStreamContainerBuilder
- java.lang.Object
-
- io.streamthoughts.azkarra.api.streams.KafkaStreamContainerBuilder
-
public class KafkaStreamContainerBuilder extends Object
Default builder class for creating and configuring a new wrappedKafkaStreams
instance.
-
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description KafkaStreamsContainer
build()
Builds aKafkaStreams
instance.static KafkaStreamContainerBuilder
newBuilder()
Creates a newKafkaStreamContainerBuilder
instance.KafkaStreamContainerBuilder
withKafkaStreamsFactory(KafkaStreamsFactory kafkaStreamsFactory)
KafkaStreamContainerBuilder
withRestoreListeners(List<org.apache.kafka.streams.processor.StateRestoreListener> listeners)
KafkaStreamContainerBuilder
withStateListeners(List<org.apache.kafka.streams.KafkaStreams.StateListener> listeners)
KafkaStreamContainerBuilder
withTopologyContainer(TopologyContainer topologyContainer)
KafkaStreamContainerBuilder
withUncaughtExceptionHandler(List<Thread.UncaughtExceptionHandler> handlers)
-
-
-
Method Detail
-
newBuilder
public static KafkaStreamContainerBuilder newBuilder()
Creates a newKafkaStreamContainerBuilder
instance.- Returns:
- a new
KafkaStreamContainerBuilder
instance.
-
withKafkaStreamsFactory
public KafkaStreamContainerBuilder withKafkaStreamsFactory(KafkaStreamsFactory kafkaStreamsFactory)
-
withTopologyContainer
public KafkaStreamContainerBuilder withTopologyContainer(TopologyContainer topologyContainer)
-
withRestoreListeners
public KafkaStreamContainerBuilder withRestoreListeners(List<org.apache.kafka.streams.processor.StateRestoreListener> listeners)
-
withUncaughtExceptionHandler
public KafkaStreamContainerBuilder withUncaughtExceptionHandler(List<Thread.UncaughtExceptionHandler> handlers)
-
withStateListeners
public KafkaStreamContainerBuilder withStateListeners(List<org.apache.kafka.streams.KafkaStreams.StateListener> listeners)
-
build
public KafkaStreamsContainer build()
Builds aKafkaStreams
instance.- Returns:
- a new
KafkaStreamsContainer
instance.
-
-