Package com.bakdata.kafka

Class CloseExecutionOptions.CloseExecutionOptionsBuilder

java.lang.Object

com.bakdata.kafka.CloseExecutionOptions.CloseExecutionOptionsBuilder

Enclosing class:

CloseExecutionOptions

public static class CloseExecutionOptions.CloseExecutionOptionsBuilder
extends Object

Method Summary

Modifier and Type	Method	Description
CloseExecutionOptions	build()
CloseExecutionOptions.CloseExecutionOptionsBuilder	closeTimeout(Duration closeTimeout)	Defines KafkaStreams.CloseOptions.timeout(Duration) and CloseOptions.withTimeout(Duration)
String	toString()
CloseExecutionOptions.CloseExecutionOptionsBuilder	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

volatileGroupInstanceId

public CloseExecutionOptions.CloseExecutionOptionsBuilder volatileGroupInstanceId(boolean volatileGroupInstanceId)

Defines if ConsumerConfig.GROUP_INSTANCE_ID_CONFIG is volatile. If set to false, KafkaStreams.CloseOptions.leaveGroup(boolean) is disabled and CloseOptions.withGroupMembershipOperation(GroupMembershipOperation) is set to CloseOptions.GroupMembershipOperation.DEFAULT.

Returns:

this.

closeTimeout

public CloseExecutionOptions.CloseExecutionOptionsBuilder closeTimeout(Duration closeTimeout)

Defines KafkaStreams.CloseOptions.timeout(Duration) and CloseOptions.withTimeout(Duration)

Returns:

this.

build

public CloseExecutionOptions build()

toString

public String toString()

Overrides:

toString in class Object