Package org.apache.storm.kafka.spout.internal

Interface ConsumerFactory<K,V>

All Superinterfaces:

Serializable

All Known Implementing Classes:

ConsumerFactoryDefault

public interface ConsumerFactory<K,V>
extends Serializable

This is here to enable testing.

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.clients.consumer.Consumer<K,V>	createConsumer(Map<String,Object> consumerProps)

Method Details

createConsumer

org.apache.kafka.clients.consumer.Consumer<K,V> createConsumer(Map<String,Object> consumerProps)