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 Details

  - ### ClientFactoryDefault

    public ClientFactoryDefault()

- ## Method Details

  - ### 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>`