Package com.bakdata.kafka.consumerproducer

Class RunningConsumerProducer.RunningConsumerProducerBuilder

java.lang.Object

com.bakdata.kafka.consumerproducer.RunningConsumerProducer.RunningConsumerProducerBuilder

Enclosing class:

RunningConsumerProducer

public static class RunningConsumerProducer.RunningConsumerProducerBuilder
extends Object

Method Summary

Modifier and Type	Method	Description
RunningConsumerProducer	build()
RunningConsumerProducer.RunningConsumerProducerBuilder	consumerConfig(@NonNull org.apache.kafka.clients.consumer.ConsumerConfig consumerConfig)
RunningConsumerProducer.RunningConsumerProducerBuilder	consumerProducerRunnable(@NonNull ConsumerProducerRunnable consumerProducerRunnable)
RunningConsumerProducer.RunningConsumerProducerBuilder	producerConfig(@NonNull org.apache.kafka.clients.producer.ProducerConfig producerConfig)
String	toString()

Methods inherited from class java.lang.Object

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

Method Details

consumerConfig

public RunningConsumerProducer.RunningConsumerProducerBuilder consumerConfig(@NonNull
 @NonNull org.apache.kafka.clients.consumer.ConsumerConfig consumerConfig)

Returns:

this.

producerConfig

public RunningConsumerProducer.RunningConsumerProducerBuilder producerConfig(@NonNull
 @NonNull org.apache.kafka.clients.producer.ProducerConfig producerConfig)

Returns:

this.

consumerProducerRunnable

public RunningConsumerProducer.RunningConsumerProducerBuilder consumerProducerRunnable(@NonNull
 @NonNull ConsumerProducerRunnable consumerProducerRunnable)

Returns:

this.

build

public RunningConsumerProducer build()

toString

public String toString()

Overrides:

toString in class Object