org.apache.nifi.processors.kafka

Class Partitioners.HashPartitioner

java.lang.Object

org.apache.nifi.processors.kafka.Partitioners.HashPartitioner

All Implemented Interfaces:

kafka.producer.Partitioner

Enclosing class:

Partitioners

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

Partitioner that implements 'key hash' mechanism which distributes the load between all available partitions based on hashing the value of the key.

Constructor Summary

Constructors

Constructor and Description
HashPartitioner()

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

HashPartitioner

public HashPartitioner()

Method Detail

partition

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

Specified by:

partition in interface kafka.producer.Partitioner