Class ConsumerFactoryDefault<K,V>

java.lang.Object
org.apache.storm.kafka.spout.internal.ConsumerFactoryDefault<K,V>
All Implemented Interfaces:
Serializable, ConsumerFactory<K,V>

public class ConsumerFactoryDefault<K,V> extends Object implements ConsumerFactory<K,V>
See Also:
  • Constructor Details

    • ConsumerFactoryDefault

      public ConsumerFactoryDefault()
  • Method Details