org.apache.nifi.processors.kafka

Class Partitioners.RoundRobinPartitioner

java.lang.Object

org.apache.nifi.processors.kafka.Partitioners.RoundRobinPartitioner

All Implemented Interfaces:

kafka.producer.Partitioner

Enclosing class:

Partitioners

public static class Partitioners.RoundRobinPartitioner
extends java.lang.Object
implements kafka.producer.Partitioner

Partitioner that implements 'round-robin' mechanism which evenly distributes load between all available partitions.

Constructor Summary

Constructors

Constructor and Description
RoundRobinPartitioner()

Method Summary

Modifier and Type	Method and Description
int	partition(java.lang.Object key, int numberOfPartitions)

Methods inherited from class java.lang.Object

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

Constructor Detail

RoundRobinPartitioner

public RoundRobinPartitioner()

Method Detail

partition

public int partition(java.lang.Object key,
                     int numberOfPartitions)

Specified by:

partition in interface kafka.producer.Partitioner