org.apache.storm.kafka.spout

Class PatternTopicFilter

java.lang.Object

org.apache.storm.kafka.spout.PatternTopicFilter

All Implemented Interfaces:

Serializable, TopicFilter

public class PatternTopicFilter
extends Object
implements TopicFilter

Filter that returns all partitions for topics matching the given Pattern.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
PatternTopicFilter(Pattern pattern) Creates filter based on a Pattern.

Method Summary

Modifier and Type	Method and Description
List<org.apache.kafka.common.TopicPartition>	getFilteredTopicPartitions(org.apache.kafka.clients.consumer.KafkaConsumer<?,?> consumer) Get the Kafka TopicPartitions passed by this filter.
String	getTopicsPattern()
String	getTopicsString()

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

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

getFilteredTopicPartitions

public List<org.apache.kafka.common.TopicPartition> getFilteredTopicPartitions(org.apache.kafka.clients.consumer.KafkaConsumer<?,?> consumer)

Description copied from interface: TopicFilter

Get the Kafka TopicPartitions passed by this filter.

Specified by:

getFilteredTopicPartitions in interface TopicFilter

Parameters:

consumer - The Kafka consumer to use to read the list of existing partitions

Returns:

The Kafka partitions passed by this filter.

getTopicsString

public String getTopicsString()

Specified by:

getTopicsString in interface TopicFilter

Returns:

A human-readable string representing the topics that pass the filter.

getTopicsPattern

public String getTopicsPattern()