org.apache.storm.kafka.spout.internal

Interface KafkaConsumerFactory<K,V>

All Superinterfaces:

Serializable

All Known Implementing Classes:

KafkaConsumerFactoryDefault

public interface KafkaConsumerFactory<K,V>
extends Serializable

This is here to enable testing

Method Summary

Modifier and Type	Method and Description
org.apache.kafka.clients.consumer.KafkaConsumer<K,V>	createConsumer(KafkaSpoutConfig<K,V> kafkaSpoutConfig)

Method Detail

createConsumer

org.apache.kafka.clients.consumer.KafkaConsumer<K,V> createConsumer(KafkaSpoutConfig<K,V> kafkaSpoutConfig)