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
DefaultConsumerAndProducerFactoryimplementation.
-
-
Constructor Summary
Constructors Constructor Description KafkaConsumerAndProducerFactory(String bootstrapServers)KafkaConsumerAndProducerFactory(Properties baseProperties)
-
Method Summary
All Methods Instance Methods Concrete Methods 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)
-
-
-
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:
createProducerin interfaceConsumerAndProducerFactory
-
createConsumer
public <K,V> org.apache.kafka.clients.consumer.Consumer<K,V> createConsumer(String topic, Class<K> keyClass, Class<V> valueClass)
- Specified by:
createConsumerin interfaceConsumerAndProducerFactory
-
-