org.apache.storm.kafka.spout

Class NamedSubscription

java.lang.Object

org.apache.storm.kafka.spout.Subscription

org.apache.storm.kafka.spout.NamedSubscription

All Implemented Interfaces:

Serializable

Deprecated.

Please use ManualPartitionSubscription with NamedTopicFilter instead

@Deprecated
public class NamedSubscription
extends Subscription

Subscribe to all topics that follow a given list of values.

See Also:

Serialized Form

Field Summary

Fields

Modifier and Type	Field and Description
protected Collection<String>	topics Deprecated.

Constructor Summary

Constructors

Constructor and Description
NamedSubscription(Collection<String> topics) Deprecated.
NamedSubscription(String... topics) 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

topics

protected final Collection<String> topics

Deprecated.

Constructor Detail

NamedSubscription

public NamedSubscription(Collection<String> topics)

Deprecated.

NamedSubscription

public NamedSubscription(String... topics)

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.