org.apache.storm.kafka.spout

Class NamedTopicFilter

java.lang.Object

org.apache.storm.kafka.spout.NamedTopicFilter

All Implemented Interfaces:

Serializable, TopicFilter

public class NamedTopicFilter
extends Object
implements TopicFilter

Filter that returns all partitions for the specified topics.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
NamedTopicFilter(Set<String> topics) Create filter based on a set of topic names.
NamedTopicFilter(String... topics) Convenience constructor.

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	getTopicsString()

Methods inherited from class java.lang.Object

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

Constructor Detail

NamedTopicFilter

public NamedTopicFilter(Set<String> topics)

Create filter based on a set of topic names.

Parameters:

topics - The topic names the filter will pass.

NamedTopicFilter

public NamedTopicFilter(String... topics)

Convenience constructor.

Parameters:

topics - The topic names the filter will pass.

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.