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	closeExecutionOptions(CloseExecutionOptions closeExecutionOptions)	Defines the behavior when closing a consumer
ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder	pollTimeout(Duration pollTimeout)	Defines the timeout duration for the Consumer.poll(Duration) call
String	toString()

Methods inherited from class java.lang.Object

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

Method Details

closeExecutionOptions

public ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder closeExecutionOptions(CloseExecutionOptions closeExecutionOptions)

Defines the behavior when closing a consumer

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