public class KafkaConsumerFactoryDefault<K,V> extends Object implements KafkaConsumerFactory<K,V>
Constructor and Description |
---|
KafkaConsumerFactoryDefault() |
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.consumer.KafkaConsumer<K,V> |
createConsumer(KafkaSpoutConfig<K,V> kafkaSpoutConfig) |
public org.apache.kafka.clients.consumer.KafkaConsumer<K,V> createConsumer(KafkaSpoutConfig<K,V> kafkaSpoutConfig)
createConsumer
in interface KafkaConsumerFactory<K,V>
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.