Package org.apache.metamodel.kafka

Class KafkaConsumerAndProducerFactory

java.lang.Object

org.apache.metamodel.kafka.KafkaConsumerAndProducerFactory

All Implemented Interfaces:

ConsumerAndProducerFactory

public class KafkaConsumerAndProducerFactory
extends Object
implements ConsumerAndProducerFactory

Default ConsumerAndProducerFactory implementation.

Constructor Summary

Constructors

Constructor	Description
KafkaConsumerAndProducerFactory(String bootstrapServers)
KafkaConsumerAndProducerFactory(Properties baseProperties)

Method Summary

Modifier and Type	Method	Description
<K,V> org.apache.kafka.clients.consumer.Consumer<K,V>	createConsumer(String topic, Class<K> keyClass, Class<V> valueClass)
<K,V> org.apache.kafka.clients.producer.Producer<K,V>	createProducer(Class<K> keyClass, Class<V> valueClass)

Methods inherited from class java.lang.Object

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

Constructor Detail

KafkaConsumerAndProducerFactory

public KafkaConsumerAndProducerFactory(String bootstrapServers)

KafkaConsumerAndProducerFactory

public KafkaConsumerAndProducerFactory(Properties baseProperties)

Method Detail

createProducer

public <K,V> org.apache.kafka.clients.producer.Producer<K,V> createProducer(Class<K> keyClass,
                                                                                        Class<V> valueClass)

Specified by:

createProducer in interface ConsumerAndProducerFactory

createConsumer

public <K,V> org.apache.kafka.clients.consumer.Consumer<K,V> createConsumer(String topic,
                                                                                        Class<K> keyClass,
                                                                                        Class<V> valueClass)

Specified by:

createConsumer in interface ConsumerAndProducerFactory