Struct RoundRobinPartitioner 

pub struct RoundRobinPartitioner { /* private fields */ }

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.

Implementations

impl RoundRobinPartitioner

pub fn new() -> Self

Creates a new RoundRobinPartitioner.

Trait Implementations

impl Debug for RoundRobinPartitioner

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for RoundRobinPartitioner

fn default() -> RoundRobinPartitioner

Returns the “default value” for a type.

impl<K, V> Partitioner<K, V> for RoundRobinPartitioner

fn partition( &self, topic: &str, _key: Option<&K>, _key_bytes: Option<&[u8]>, _value: Option<&V>, _value_bytes: Option<&[u8]>, cluster: &Cluster, ) -> i32

Compute the partition for the given record.

fn configure(&mut self, _configs: &HashMap<String, String>)

Configure this class with the given key-value pairs

fn close(&self)

This is called when partitioner is closed.