public interface KafkaConsumerFactory<K,V> extends Serializable
This is here to enable testing
Modifier and Type | Method and Description |
---|---|
org.apache.kafka.clients.consumer.KafkaConsumer<K,V> |
createConsumer(KafkaSpoutConfig<K,V> kafkaSpoutConfig) |
org.apache.kafka.clients.consumer.KafkaConsumer<K,V> createConsumer(KafkaSpoutConfig<K,V> kafkaSpoutConfig)
Copyright © 2022 The Apache Software Foundation. All Rights Reserved.