Package com.bakdata.kafka.consumer

Class ConsumerExecutionOptions

java.lang.Object

com.bakdata.kafka.consumer.ConsumerExecutionOptions

public class ConsumerExecutionOptions
extends Object

Options to run a Kafka Consumer app

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder

Method Summary

Modifier and Type	Method	Description
static ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder	builder()
Duration	getPollTimeout()	Defines the timeout duration for the Consumer.poll(Duration) call

Methods inherited from class java.lang.Object

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

Method Details

builder

public static ConsumerExecutionOptions.ConsumerExecutionOptionsBuilder builder()

getPollTimeout

public Duration getPollTimeout()

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