Class PatternTopicFilter
- java.lang.Object
-
- org.apache.storm.kafka.spout.subscription.PatternTopicFilter
-
- All Implemented Interfaces:
Serializable,TopicFilter
public class PatternTopicFilter extends Object implements TopicFilter
Filter that returns all partitions for topics matching the givenPattern.- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description PatternTopicFilter(Pattern pattern)Creates filter based on a Pattern.
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description Set<org.apache.kafka.common.TopicPartition>getAllSubscribedPartitions(org.apache.kafka.clients.consumer.Consumer<?,?> consumer)Get the Kafka TopicPartitions subscribed to by this set of spouts.StringgetTopicsPattern()StringgetTopicsString()Get the topics string.
-
-
-
Constructor Detail
-
PatternTopicFilter
public PatternTopicFilter(Pattern pattern)
Creates filter based on a Pattern. Only topic names matching the Pattern are passed by the filter.- Parameters:
pattern- The Pattern to use.
-
-
Method Detail
-
getAllSubscribedPartitions
public Set<org.apache.kafka.common.TopicPartition> getAllSubscribedPartitions(org.apache.kafka.clients.consumer.Consumer<?,?> consumer)
Description copied from interface:TopicFilterGet the Kafka TopicPartitions subscribed to by this set of spouts.- Specified by:
getAllSubscribedPartitionsin interfaceTopicFilter- Parameters:
consumer- The Kafka consumer to use to read the list of existing partitions- Returns:
- The Kafka partitions this set of spouts should subscribe to
-
getTopicsString
public String getTopicsString()
Description copied from interface:TopicFilterGet the topics string.- Specified by:
getTopicsStringin interfaceTopicFilter- Returns:
- A human-readable string representing the topics that pass the filter.
-
getTopicsPattern
public String getTopicsPattern()
-
-