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	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)
StreamsExecutionOptions.StreamsExecutionOptionsBuilder	volatileGroupInstanceId(boolean volatileGroupInstanceId)	Defines if ConsumerConfig.GROUP_INSTANCE_ID_CONFIG is volatile.

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.

volatileGroupInstanceId

public StreamsExecutionOptions.StreamsExecutionOptionsBuilder volatileGroupInstanceId(boolean volatileGroupInstanceId)

Defines if ConsumerConfig.GROUP_INSTANCE_ID_CONFIG is volatile. If it is configured and non-volatile, KafkaStreams.close(CloseOptions) is called with KafkaStreams.CloseOptions.leaveGroup(boolean) disabled

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