Class ClientFactoryDefault<K,V> 
java.lang.Object
org.apache.storm.kafka.spout.internal.ClientFactoryDefault<K,V> 
- All Implemented Interfaces:
- Serializable,- ClientFactory<K,- V> 
- See Also:
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionorg.apache.kafka.clients.admin.AdmincreateAdmin(Map<String, Object> adminProps) createConsumer(Map<String, Object> consumerProps) 
- 
Constructor Details- 
ClientFactoryDefaultpublic ClientFactoryDefault()
 
- 
- 
Method Details- 
createConsumerpublic org.apache.kafka.clients.consumer.KafkaConsumer<K,V> createConsumer(Map<String, Object> consumerProps) - Specified by:
- createConsumerin interface- ClientFactory<K,- V> 
 
- 
createAdmin- Specified by:
- createAdminin interface- ClientFactory<K,- V> 
 
 
-