Package com.bakdata.kafka.consumer

Class ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder

java.lang.Object

com.bakdata.kafka.consumer.ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder

Enclosing class:

ConsumerExecutionOptions

public static class ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder
extends Object

Method Summary

Modifier and Type	Method	Description
ConsumerExecutionOptions	build()
ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder	closeTimeout(Duration closeTimeout)	Defines CloseOptions.timeout(Duration) when calling Consumer.close(CloseOptions)
ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder	onStart(Consumer<RunningConsumer> onStart)	Hook that is called after the ConsumerRunnable is started
ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder	pollTimeout(Duration pollTimeout)	Defines the timeout duration for the Consumer.poll(Duration) call
String	toString()
ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder	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 ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder onStart(@NonNull
 Consumer<RunningConsumer> onStart)

Hook that is called after the ConsumerRunnable is started

Returns:

this.

volatileGroupInstanceId

public ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder volatileGroupInstanceId(boolean volatileGroupInstanceId)

Defines if ConsumerConfig.GROUP_INSTANCE_ID_CONFIG is volatile. If it is configured and non-volatile, Consumer.close(CloseOptions) is called with CloseOptions.groupMembershipOperation(GroupMembershipOperation) set to CloseOptions.GroupMembershipOperation.REMAIN_IN_GROUP

Returns:

this.

closeTimeout

public ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder closeTimeout(Duration closeTimeout)

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

Returns:

this.

pollTimeout

public ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder pollTimeout(Duration pollTimeout)

Defines the timeout duration for the Consumer.poll(Duration) call

Returns:

this.

build

public ConsumerExecutionOptions build()

toString

public String toString()

Overrides:

toString in class Object