Uses of Interface
org.apache.storm.kafka.spout.subscription.TopicFilter
-
Packages that use TopicFilter Package Description org.apache.storm.kafka.spout org.apache.storm.kafka.spout.internal org.apache.storm.kafka.spout.subscription org.apache.storm.kafka.spout.trident -
-
Uses of TopicFilter in org.apache.storm.kafka.spout
Constructors in org.apache.storm.kafka.spout with parameters of type TopicFilter Constructor Description Builder(String bootstrapServers, TopicFilter topicFilter, ManualPartitioner topicPartitioner)
Create a KafkaSpoutConfig builder with default property values and no key/value deserializers. -
Uses of TopicFilter in org.apache.storm.kafka.spout.internal
Methods in org.apache.storm.kafka.spout.internal that return TopicFilter Modifier and Type Method Description TopicFilter
CommonKafkaSpoutConfig. getTopicFilter()
Constructors in org.apache.storm.kafka.spout.internal with parameters of type TopicFilter Constructor Description Builder(String bootstrapServers, TopicFilter topicFilter, ManualPartitioner topicPartitioner)
Create a KafkaSpoutConfig builder with default property values and no key/value deserializers. -
Uses of TopicFilter in org.apache.storm.kafka.spout.subscription
Classes in org.apache.storm.kafka.spout.subscription that implement TopicFilter Modifier and Type Class Description class
NamedTopicFilter
Filter that returns all partitions for the specified topics.class
PatternTopicFilter
Filter that returns all partitions for topics matching the givenPattern
. -
Uses of TopicFilter in org.apache.storm.kafka.spout.trident
Constructors in org.apache.storm.kafka.spout.trident with parameters of type TopicFilter Constructor Description Builder(String bootstrapServers, TopicFilter topicFilter, ManualPartitioner topicPartitioner)
-