Struct RangeAssignor 

pub struct RangeAssignor;

Contiguous ranges per topic, Java’s RangeAssignor.

For each topic the subscribed members are sorted by id and the partitions split into contiguous blocks. With 7 partitions and 3 members the split is 3/2/2, the remainder going to the earliest members.

It is deliberately not balanced across topics. With several topics of few partitions the first member accumulates the leftovers of each — the known wart of this strategy, and the reason RoundRobin exists. Reproduced rather than fixed, because a member that “fixes” it disagrees with the Java members in the same group.

Trait Implementations

impl Assignor for RangeAssignor

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 RangeAssignor

fn clone(&self) -> RangeAssignor

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for RangeAssignor

impl Debug for RangeAssignor

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

Formats the value using the given formatter.

impl Default for RangeAssignor

fn default() -> RangeAssignor

Returns the “default value” for a type.