public class KafkaConsumerAndProducerFactory extends Object implements ConsumerAndProducerFactory
ConsumerAndProducerFactory
implementation.Constructor and Description |
---|
KafkaConsumerAndProducerFactory(Properties baseProperties) |
KafkaConsumerAndProducerFactory(String bootstrapServers) |
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) |
public KafkaConsumerAndProducerFactory(String bootstrapServers)
public KafkaConsumerAndProducerFactory(Properties baseProperties)
public <K,V> org.apache.kafka.clients.producer.Producer<K,V> createProducer(Class<K> keyClass, Class<V> valueClass)
createProducer
in interface ConsumerAndProducerFactory
public <K,V> org.apache.kafka.clients.consumer.Consumer<K,V> createConsumer(String topic, Class<K> keyClass, Class<V> valueClass)
createConsumer
in interface ConsumerAndProducerFactory
Copyright © 2007–2021 The Apache Software Foundation. All rights reserved.