Uses of Class
org.apache.storm.kafka.spout.Subscription

Packages that use Subscription

Package	Description
org.apache.storm.kafka.spout

Uses of Subscription in org.apache.storm.kafka.spout

Subclasses of Subscription in org.apache.storm.kafka.spout

Modifier and Type	Class and Description
class	ManualPartitionSubscription
class	NamedSubscription Deprecated. Please use ManualPartitionSubscription with NamedTopicFilter instead
class	PatternSubscription Deprecated. Please use ManualPartitionSubscription with PatternTopicFilter instead

Methods in org.apache.storm.kafka.spout that return Subscription

Modifier and Type	Method and Description
Subscription	KafkaSpoutConfig.getSubscription()

Constructors in org.apache.storm.kafka.spout with parameters of type Subscription

Constructor and Description
Builder(String bootstrapServers, Class<? extends org.apache.kafka.common.serialization.Deserializer<K>> keyDes, Class<? extends org.apache.kafka.common.serialization.Deserializer<V>> valDes, Subscription subscription) Deprecated. Please use #Builder(java.lang.String, org.apache.storm.kafka.spout.Subscription) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG
Builder(String bootstrapServers, SerializableDeserializer<K> keyDes, SerializableDeserializer<V> valDes, Subscription subscription) Deprecated. Please use #Builder(java.lang.String, org.apache.storm.kafka.spout.Subscription) instead, and set the deserializer with KafkaSpoutConfig.Builder.setProp(java.lang.String, java.lang.Object), ConsumerConfig.KEY_DESERIALIZER_CLASS_CONFIG and ConsumerConfig.VALUE_DESERIALIZER_CLASS_CONFIG
Builder(String bootstrapServers, Subscription subscription) Create a KafkaSpoutConfig builder with default property values and no key/value deserializers.