Package com.bakdata.kafka.streams

Class StreamsExecutionOptions.StreamsExecutionOptionsBuilder

java.lang.Object

com.bakdata.kafka.streams.StreamsExecutionOptions.StreamsExecutionOptionsBuilder

Enclosing class:

StreamsExecutionOptions

public static class StreamsExecutionOptions.StreamsExecutionOptionsBuilder
extends Object

Method Summary

Modifier and Type	Method	Description
StreamsExecutionOptions	build()
StreamsExecutionOptions.StreamsExecutionOptionsBuilder	closeExecutionOptions(CloseExecutionOptions closeExecutionOptions)	Defines the behavior when closing a Kafka Streams app using KafkaStreams.close(CloseOptions).
StreamsExecutionOptions.StreamsExecutionOptionsBuilder	closeTimeout(Duration closeTimeout)	Defines KafkaStreams.CloseOptions.timeout(Duration) when calling KafkaStreams.close(CloseOptions)
StreamsExecutionOptions.StreamsExecutionOptionsBuilder	onStart(@NonNull Consumer<RunningStreams> onStart)	Hook that is called after calling KafkaStreams.start()
StreamsExecutionOptions.StreamsExecutionOptionsBuilder	stateListener(@NonNull Supplier<org.apache.kafka.streams.KafkaStreams.StateListener> stateListener)	Configures KafkaStreams.setStateListener(StateListener)
String	toString()
StreamsExecutionOptions.StreamsExecutionOptionsBuilder	uncaughtExceptionHandler(@NonNull Supplier<org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler> uncaughtExceptionHandler)	Configures KafkaStreams.setUncaughtExceptionHandler(StreamsUncaughtExceptionHandler)

Methods inherited from class java.lang.Object

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

Method Details

onStart

public StreamsExecutionOptions.StreamsExecutionOptionsBuilder onStart(@NonNull
 @NonNull Consumer<RunningStreams> onStart)

Hook that is called after calling KafkaStreams.start()

Returns:

this.

stateListener

public StreamsExecutionOptions.StreamsExecutionOptionsBuilder stateListener(@NonNull
 @NonNull Supplier<org.apache.kafka.streams.KafkaStreams.StateListener> stateListener)

Configures KafkaStreams.setStateListener(StateListener)

Returns:

this.

uncaughtExceptionHandler

public StreamsExecutionOptions.StreamsExecutionOptionsBuilder uncaughtExceptionHandler(@NonNull
 @NonNull Supplier<org.apache.kafka.streams.errors.StreamsUncaughtExceptionHandler> uncaughtExceptionHandler)

Configures KafkaStreams.setUncaughtExceptionHandler(StreamsUncaughtExceptionHandler)

Returns:

this.

closeExecutionOptions

public StreamsExecutionOptions.StreamsExecutionOptionsBuilder closeExecutionOptions(CloseExecutionOptions closeExecutionOptions)

Defines the behavior when closing a Kafka Streams app using KafkaStreams.close(CloseOptions).

Returns:

this.

closeTimeout

public StreamsExecutionOptions.StreamsExecutionOptionsBuilder closeTimeout(Duration closeTimeout)

Defines KafkaStreams.CloseOptions.timeout(Duration) when calling KafkaStreams.close(CloseOptions)

Returns:

this.

build

public StreamsExecutionOptions build()

toString

public String toString()

Overrides:

toString in class Object