Package org.apache.storm.kafka.spout.subscription
package org.apache.storm.kafka.spout.subscription
-
ClassDescriptionA function used to assign partitions to this spout.Filter that returns all partitions for the specified topics.Filter that returns all partitions for topics matching the given
Pattern.Assign partitions in a round robin fashion for all spouts, not just the ones that are alive.Handles assigning partitions to the consumer and updating the rebalance listener.