Package com.bakdata.kafka.consumerproducer

Class ConsumerProducerExecutionOptions.ConsumerProducerExecutionOptionsBuilder

java.lang.Object

com.bakdata.kafka.consumerproducer.ConsumerProducerExecutionOptions.ConsumerProducerExecutionOptionsBuilder

Enclosing class:

ConsumerProducerExecutionOptions

public static class ConsumerProducerExecutionOptions.ConsumerProducerExecutionOptionsBuilder
extends Object

Method Summary

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

Hook that is called after the ConsumerProducerRunnable is started

Returns:

this.

volatileGroupInstanceId

public ConsumerProducerExecutionOptions.ConsumerProducerExecutionOptionsBuilder 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 ConsumerProducerExecutionOptions.ConsumerProducerExecutionOptionsBuilder closeTimeout(Duration closeTimeout)

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

Returns:

this.

pollTimeout

public ConsumerProducerExecutionOptions.ConsumerProducerExecutionOptionsBuilder pollTimeout(Duration pollTimeout)

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

Returns:

this.

build

public ConsumerProducerExecutionOptions build()

toString

public String toString()

Overrides:

toString in class Object