public interface ConsumerAndProducerFactory
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.Modifier and Type | Method and 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) |
Copyright © 2007–2020 The Apache Software Foundation. All rights reserved.