Struct Assignment 

pub struct Assignment { /* private fields */ }

A consumer member’s assignment.

Corresponds to ConsumerPartitionAssignor.Assignment.

Implementations

impl Assignment

pub fn new(partitions: Vec<TopicPartition>) -> Self

Creates an assignment from partitions only.

Mirrors Assignment(List) (:184).

pub fn with_user_data( partitions: Vec<TopicPartition>, user_data: Option<Vec<u8>>, ) -> Self

Creates an assignment with partitions and optional user data.

Mirrors Assignment(List, ByteBuffer) (:179).

pub fn partitions(&self) -> &[TopicPartition]

The assigned partitions.

pub fn user_data(&self) -> Option<&[u8]>

The opaque user data attached to the assignment.

Trait Implementations

impl Clone for Assignment

fn clone(&self) -> Assignment

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for Assignment

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

Formats the value using the given formatter.

impl PartialEq for Assignment

fn eq(&self, other: &Assignment) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl Eq for Assignment

impl StructuralPartialEq for Assignment