Class ConsumerFactoryDefault<K,V>
java.lang.Object
org.apache.storm.kafka.spout.internal.ConsumerFactoryDefault<K,V>
- All Implemented Interfaces:
Serializable
,ConsumerFactory<K,
V>
- See Also:
-
Constructor Summary
-
Method Summary
-
Constructor Details
-
ConsumerFactoryDefault
public ConsumerFactoryDefault()
-
-
Method Details
-
createConsumer
public org.apache.kafka.clients.consumer.KafkaConsumer<K,V> createConsumer(Map<String, Object> consumerProps) - Specified by:
createConsumer
in interfaceConsumerFactory<K,
V>
-