org.apache.storm.kafka.spout

Class RoundRobinManualPartitioner

java.lang.Object

org.apache.storm.kafka.spout.RoundRobinManualPartitioner

All Implemented Interfaces:

Serializable, ManualPartitioner

public class RoundRobinManualPartitioner
extends Object
implements ManualPartitioner

Assign partitions in a round robin fashion for all spouts, not just the ones that are alive. Because the parallelism of the spouts does not typically change while running this makes the assignments more stable in the face of crashing spouts.

Round Robin means that first spout of N spouts will get the first partition, and the N+1th partition… The second spout will get the second partition and N+2th partition etc.

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
RoundRobinManualPartitioner()

Method Summary

Modifier and Type	Method and Description
List<org.apache.kafka.common.TopicPartition>	partition(List<org.apache.kafka.common.TopicPartition> allPartitions, TopologyContext context) Get the partitions for this assignment

Methods inherited from class java.lang.Object

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

Constructor Detail

RoundRobinManualPartitioner

public RoundRobinManualPartitioner()

Method Detail

partition

public List<org.apache.kafka.common.TopicPartition> partition(List<org.apache.kafka.common.TopicPartition> allPartitions,
                                                              TopologyContext context)

Description copied from interface: ManualPartitioner

Get the partitions for this assignment

Specified by:

partition in interface ManualPartitioner

Parameters:

allPartitions - all of the partitions that the set of spouts want to subscribe to, in a strict ordering

context - the context of the topology

Returns:

the subset of the partitions that this spout should use.