Class RoundRobinPartitioner
java.lang.Object
org.apache.kafka.clients.producer.RoundRobinPartitioner
- All Implemented Interfaces:
Closeable
,AutoCloseable
,Partitioner
,Configurable
The "Round-Robin" partitioner
This partitioning strategy can be used when user wants
to distribute the writes to all partitions equally. This
is the behaviour regardless of record key hash.
-
Constructor Summary
-
Method Summary
Modifier and TypeMethodDescriptionvoid
close()
This is called when partitioner is closed.void
Configure this class with the given key-value pairsint
partition
(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster) Compute the partition for the given record.Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
Methods inherited from interface org.apache.kafka.clients.producer.Partitioner
onNewBatch
-
Constructor Details
-
RoundRobinPartitioner
public RoundRobinPartitioner()
-
-
Method Details
-
configure
Description copied from interface:Configurable
Configure this class with the given key-value pairs- Specified by:
configure
in interfaceConfigurable
-
partition
public int partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster) Compute the partition for the given record.- Specified by:
partition
in interfacePartitioner
- Parameters:
topic
- The topic namekey
- The key to partition on (or null if no key)keyBytes
- serialized key to partition on (or null if no key)value
- The value to partition on or nullvalueBytes
- serialized value to partition on or nullcluster
- The current cluster metadata
-
close
public void close()Description copied from interface:Partitioner
This is called when partitioner is closed.- Specified by:
close
in interfaceAutoCloseable
- Specified by:
close
in interfaceCloseable
- Specified by:
close
in interfacePartitioner
-