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

Class ClientFactoryDefault<K,V>

java.lang.Object

org.apache.storm.kafka.spout.internal.ClientFactoryDefault<K,V>

All Implemented Interfaces:

Serializable, ClientFactory<K,V>

public class ClientFactoryDefault<K,V>
extends Object
implements ClientFactory<K,V>

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor	Description
ClientFactoryDefault()

Method Summary

Modifier and Type	Method	Description
org.apache.kafka.clients.admin.Admin	createAdmin(Map<String,Object> adminProps)
org.apache.kafka.clients.consumer.KafkaConsumer<K,V>	createConsumer(Map<String,Object> consumerProps)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ClientFactoryDefault

public ClientFactoryDefault()

Method Detail

createConsumer

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

Specified by:

createConsumer in interface ClientFactory<K,V>

createAdmin

public org.apache.kafka.clients.admin.Admin createAdmin(Map<String,Object> adminProps)

Specified by:

createAdmin in interface ClientFactory<K,V>