Package org.apache.metamodel.kafka

Interface ConsumerAndProducerFactory

All Known Implementing Classes:

KafkaConsumerAndProducerFactory

public interface ConsumerAndProducerFactory

Factory interface for Kafka Consumer and Producer objects to be used by Apache MetaModel. Since Apache MetaModel may potentially serve multiple queries at the same times, multiple consumers may be needed. This class determines how these are instantiated.

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)

Method Detail

createConsumer

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

createProducer

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