Package com.bakdata.kafka.consumerproducer

Class ConsumerProducerExecutionOptions

java.lang.Object

com.bakdata.kafka.consumerproducer.ConsumerProducerExecutionOptions

public final class ConsumerProducerExecutionOptions
extends Object

Options to run a Kafka ConsumerProducer app

Nested Class Summary

Nested Classes

Modifier and Type	Class	Description
static class	ConsumerProducerExecutionOptions.ConsumerProducerExecutionOptionsBuilder

Method Summary

Modifier and Type	Method	Description
static ConsumerProducerExecutionOptions.ConsumerProducerExecutionOptionsBuilder	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 ConsumerProducerExecutionOptions.ConsumerProducerExecutionOptionsBuilder builder()

getPollTimeout

public Duration getPollTimeout()

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