public class RoundRobinPartitioner extends Object implements Partitioner
| Constructor and Description |
|---|
RoundRobinPartitioner() |
| Modifier and Type | Method and Description |
|---|---|
void | close()This is called when partitioner is closed. |
void | configure(Map<String,?> configs)Configure this class with the given key-value pairs |
int | partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster)Compute the partition for the given record. |
equals, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitonNewBatchpublic void configure(Map<String,?> configs)
Configurableconfigure in interface Configurablepublic int partition(String topic, Object key, byte[] keyBytes, Object value, byte[] valueBytes, Cluster cluster)
partition in interface Partitionertopic - 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 metadatapublic void close()
Partitionerclose in interface Closeableclose in interface AutoCloseableclose in interface Partitioner