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

# Interface ClientFactory<K,V>

All Superinterfaces:
  `Serializable`

All Known Implementing Classes:
  `ClientFactoryDefault`

public interface ClientFactory<K,V> extends Serializable
This is here to enable testing.

- ## Method Summary

  Modifier and Type
  Method
  Description
  `org.apache.kafka.clients.admin.Admin`
  `createAdmin(Map<String,Object> adminProps)`
  `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)

  - ### createAdmin

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