org.apache.storm.kafka.spout

Class PatternSubscription

java.lang.Object

org.apache.storm.kafka.spout.Subscription

org.apache.storm.kafka.spout.PatternSubscription

All Implemented Interfaces:

Serializable

Deprecated.

Please use ManualPartitionSubscription with PatternTopicFilter instead

@Deprecated
public class PatternSubscription
extends Subscription

Subscribe to all topics that match a given pattern.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Pattern	pattern Deprecated.

Constructor Summary

Constructors

Constructor and Description
PatternSubscription(Pattern pattern) Deprecated.

Method Summary

Modifier and Type	Method and Description
String	getTopicsString() Deprecated.
<K,V> void	subscribe(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer, org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener, TopologyContext unused) Deprecated. Subscribe the KafkaConsumer to the proper topics.

Methods inherited from class org.apache.storm.kafka.spout.Subscription

refreshAssignment

Methods inherited from class java.lang.Object

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

Field Detail

pattern

protected final Pattern pattern

Deprecated.

Constructor Detail

PatternSubscription

public PatternSubscription(Pattern pattern)

Deprecated.

Method Detail

subscribe

public <K,V> void subscribe(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer,
                            org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener,
                            TopologyContext unused)

Deprecated.

Description copied from class: Subscription

Subscribe the KafkaConsumer to the proper topics. Implementations must ensure that a given topic partition is always assigned to the same spout task. Adding and removing partitions as necessary is fine, but partitions must not move from one task to another. This constraint is only important for use with the Trident spout.

Specified by:

subscribe in class Subscription

Parameters:

consumer - the Consumer to get.

listener - the rebalance listener to include in the subscription

getTopicsString

public String getTopicsString()

Deprecated.

Specified by:

getTopicsString in class Subscription

Returns:

A human-readable string representing the subscribed topics.