Class PatternTopicFilter
java.lang.Object
org.apache.storm.kafka.spout.subscription.PatternTopicFilter
- All Implemented Interfaces:
- Serializable,- TopicFilter
Filter that returns all partitions for topics matching the given 
Pattern.- See Also:
- 
Constructor SummaryConstructors
- 
Method SummaryModifier and TypeMethodDescriptionSet<org.apache.kafka.common.TopicPartition>getAllSubscribedPartitions(org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) Get the Kafka TopicPartitions subscribed to by this set of spouts.Get the topics string.
- 
Constructor Details- 
PatternTopicFilterCreates filter based on a Pattern. Only topic names matching the Pattern are passed by the filter.- Parameters:
- pattern- The Pattern to use.
 
 
- 
- 
Method Details- 
getAllSubscribedPartitionspublic 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 interface- TopicFilter
- 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
 
- 
getTopicsStringDescription copied from interface:TopicFilterGet the topics string.- Specified by:
- getTopicsStringin interface- TopicFilter
- Returns:
- A human-readable string representing the topics that pass the filter.
 
- 
getTopicsPattern
 
-