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 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)