Package com.bakdata.kafka.consumerproducer

Class DefaultConsumerProducerRunnable<KOut,VOut>

java.lang.Object

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

Type Parameters:

KOut - type of keys produced by this runnable

VOut - type of values produced by this runnable

All Implemented Interfaces:

ConsumerProducerRunnable, AutoCloseable

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

Creates a ConsumerProducerRunnable using the provided ConsumerRunnable and Producer.

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()
void	run(org.apache.kafka.clients.consumer.ConsumerConfig consumerConfig)	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)

Description copied from interface: ConsumerProducerRunnable

Produce or Consume messages from Kafka

Specified by:

run in interface ConsumerProducerRunnable

Parameters:

consumerConfig - configuration for the consumer

close

public void close()

Specified by:

close in interface AutoCloseable

Specified by:

close in interface ConsumerProducerRunnable