org.apache.storm.kafka.spout

Class ManualPartitionSubscription

java.lang.Object

org.apache.storm.kafka.spout.Subscription

org.apache.storm.kafka.spout.ManualPartitionSubscription

All Implemented Interfaces:

Serializable

public class ManualPartitionSubscription
extends Subscription

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
ManualPartitionSubscription(ManualPartitioner parter, TopicFilter partitionFilter)

Method Summary

Modifier and Type	Method and Description
String	getTopicsString()
void	refreshAssignment() NOOP is the default behavior, which means that Kafka will internally handle partition assignment.
<K,V> void	subscribe(org.apache.kafka.clients.consumer.KafkaConsumer<K,V> consumer, org.apache.kafka.clients.consumer.ConsumerRebalanceListener listener, TopologyContext context) Subscribe the KafkaConsumer to the proper topics.

Methods inherited from class java.lang.Object

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

Constructor Detail

ManualPartitionSubscription

public ManualPartitionSubscription(ManualPartitioner parter,
                                   TopicFilter partitionFilter)

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 context)

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

refreshAssignment

public void refreshAssignment()

Description copied from class: Subscription

NOOP is the default behavior, which means that Kafka will internally handle partition assignment. If you wish to do manual partition management, you must provide an implementation of this method that will check with kafka for any changes and call the ConsumerRebalanceListener from subscribe to inform the rest of the system of those changes.

Overrides:

refreshAssignment in class Subscription

getTopicsString

public String getTopicsString()

Specified by:

getTopicsString in class Subscription

Returns:

A human-readable string representing the subscribed topics.