Package com.bakdata.kafka.consumerproducer

Class DefaultConsumerProducerRunnable<KOut,VOut>

java.lang.Object

com.bakdata.kafka.consumerproducer.DefaultConsumerProducerRunnable<KOut,VOut>

All Implemented Interfaces:

ConsumerProducerRunnable, AutoCloseable

public class DefaultConsumerProducerRunnable<KOut,VOut>
extends Object
implements ConsumerProducerRunnable

Constructor Summary

Constructors

Constructor	Description
DefaultConsumerProducerRunnable(org.apache.kafka.clients.producer.Producer<KOut,VOut> producer, ConsumerRunnable consumerRunnable)

Method Summary

Modifier and Type	Method	Description
void	close()
ConsumerRunnable	getConsumerRunnable()
void	run(org.apache.kafka.clients.consumer.ConsumerConfig consumerConfig, org.apache.kafka.clients.producer.ProducerConfig producerConfig)	Produce or Consume messages from Kafka

Methods inherited from class java.lang.Object

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

Constructor Details

DefaultConsumerProducerRunnable

public DefaultConsumerProducerRunnable(org.apache.kafka.clients.producer.Producer<KOut,VOut> producer,
 ConsumerRunnable consumerRunnable)

Method Details

run

public void run(org.apache.kafka.clients.consumer.ConsumerConfig consumerConfig,
 org.apache.kafka.clients.producer.ProducerConfig producerConfig)

Description copied from interface: ConsumerProducerRunnable

Produce or Consume messages from Kafka

Specified by:

run in interface ConsumerProducerRunnable

Parameters:

consumerConfig - configuration for the consumer

producerConfig - configuration for the producer

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ConsumerProducerRunnable

getConsumerRunnable

public ConsumerRunnable getConsumerRunnable()