Package org.apache.storm.kafka.spout.subscription

Interface Summary

Interface	Description
ManualPartitioner	A function used to assign partitions to this spout.
TopicFilter

Class Summary

Class	Description
NamedTopicFilter	Filter that returns all partitions for the specified topics.
PatternTopicFilter	Filter that returns all partitions for topics matching the given Pattern.
RoundRobinManualPartitioner	Assign partitions in a round robin fashion for all spouts, not just the ones that are alive.
TopicAssigner	Handles assigning partitions to the consumer and updating the rebalance listener.