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 Detail

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)