public class ConsumerFactoryDefault<K,V> extends Object implements ConsumerFactory<K,V>
Constructor and Description |
---|
ConsumerFactoryDefault() |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.consumer.KafkaConsumer<K,V> |
createConsumer(Map<String,Object> consumerProps) |
public org.apache.kafka.clients.consumer.KafkaConsumer<K,V> createConsumer(Map<String,Object> consumerProps)
createConsumer
in interface ConsumerFactory<K,V>
Copyright © 2019 The Apache Software Foundation. All rights reserved.