Class LocalKafkaStreamsContainerBuilder
- java.lang.Object
-
- io.streamthoughts.azkarra.runtime.streams.LocalKafkaStreamsContainerBuilder
-
public class LocalKafkaStreamsContainerBuilder extends Object
Default builder class for creating and configuring a new wrappedKafkaStreams
instance.
-
-
Constructor Summary
Constructors Constructor Description LocalKafkaStreamsContainerBuilder()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description LocalKafkaStreamsContainer
build()
Builds aKafkaStreams
instance.LocalKafkaStreamsContainerBuilder
withContainerId(String containerId)
LocalKafkaStreamsContainerBuilder
withInterceptors(List<StreamsLifecycleInterceptor> interceptors)
LocalKafkaStreamsContainerBuilder
withKafkaStreamsFactory(KafkaStreamsFactory kafkaStreamsFactory)
LocalKafkaStreamsContainerBuilder
withRestoreListeners(List<org.apache.kafka.streams.processor.StateRestoreListener> listeners)
LocalKafkaStreamsContainerBuilder
withStateListeners(List<org.apache.kafka.streams.KafkaStreams.StateListener> listeners)
LocalKafkaStreamsContainerBuilder
withStreamsConfig(Conf streamsConfig)
LocalKafkaStreamsContainerBuilder
withStreamThreadExceptionHandlers(List<StreamThreadExceptionHandler> handlers)
LocalKafkaStreamsContainerBuilder
withTopologyDefinition(TopologyDefinition topologyDefinition)
-
-
-
Method Detail
-
withContainerId
public LocalKafkaStreamsContainerBuilder withContainerId(String containerId)
-
withStreamsConfig
public LocalKafkaStreamsContainerBuilder withStreamsConfig(Conf streamsConfig)
-
withInterceptors
public LocalKafkaStreamsContainerBuilder withInterceptors(List<StreamsLifecycleInterceptor> interceptors)
-
withKafkaStreamsFactory
public LocalKafkaStreamsContainerBuilder withKafkaStreamsFactory(KafkaStreamsFactory kafkaStreamsFactory)
-
withTopologyDefinition
public LocalKafkaStreamsContainerBuilder withTopologyDefinition(TopologyDefinition topologyDefinition)
-
withRestoreListeners
public LocalKafkaStreamsContainerBuilder withRestoreListeners(List<org.apache.kafka.streams.processor.StateRestoreListener> listeners)
-
withStreamThreadExceptionHandlers
public LocalKafkaStreamsContainerBuilder withStreamThreadExceptionHandlers(List<StreamThreadExceptionHandler> handlers)
-
withStateListeners
public LocalKafkaStreamsContainerBuilder withStateListeners(List<org.apache.kafka.streams.KafkaStreams.StateListener> listeners)
-
build
public LocalKafkaStreamsContainer build()
Builds aKafkaStreams
instance.- Returns:
- a new
KafkaStreamsContainer
instance.
-
-