Struct RoundRobinAssignor 

pub struct RoundRobinAssignor;

One partition at a time around the members, Java’s RoundRobinAssignor.

Every (topic, partition) in the group is laid out in order and dealt to the members in turn, skipping a member that did not subscribe to that topic. Balances across topics, which Range does not; in exchange it moves almost every partition when membership changes, which is what sticky addresses.

Trait Implementations

impl Assignor for RoundRobinAssignor

fn name(&self) -> &'static str

The protocol name Kafka knows this by.

fn assign( &self, members: &[Subscription], partitions_per_topic: &BTreeMap<String, i32>, ) -> Assignment

Divide partitions_per_topic among members.

impl Clone for RoundRobinAssignor

fn clone(&self) -> RoundRobinAssignor

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Copy for RoundRobinAssignor

impl Debug for RoundRobinAssignor

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

Formats the value using the given formatter.

impl Default for RoundRobinAssignor

fn default() -> RoundRobinAssignor

Returns the “default value” for a type.