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 Summary
Constructors -
Method Summary
Modifier 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
-
PatternTopicFilter
Creates filter based on a Pattern. Only topic names matching the Pattern are passed by the filter.- Parameters:
pattern
- The Pattern to use.
-
-
Method Details
-
getAllSubscribedPartitions
public Set<org.apache.kafka.common.TopicPartition> getAllSubscribedPartitions(org.apache.kafka.clients.consumer.Consumer<?, ?> consumer) Description copied from interface:TopicFilter
Get the Kafka TopicPartitions subscribed to by this set of spouts.- Specified by:
getAllSubscribedPartitions
in 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
Description copied from interface:TopicFilter
Get the topics string.- Specified by:
getTopicsString
in interfaceTopicFilter
- Returns:
- A human-readable string representing the topics that pass the filter.
-
getTopicsPattern
-