Struct Partition

pub struct Partition<'a> { /* private fields */ }

Metadata about a particular topic partition.

A partition can be seen as either available or not by kafka-rust. “Available” partitions are partitions with an assigned leader broker and can be send messages to or fetched messages from. Non-available partitions are ignored by kafka-rust. Whether or not a partition is currently “available” can be determined by testing for partition.leader().is_some() or more directly through partition.is_available().

Implementations

impl<'a> Partition<'a>

pub fn id(&self) -> i32

Retrieves the identifier of this topic partition.

pub fn leader(&self) -> Option<&'a Broker>

Retrieves the current leader broker of this partition - if any. A partition with a leader is said to be “available”.

pub fn is_available(&self) -> bool

Determines whether this partition is currently “available”. See Partition::leader().

Trait Implementations

impl<'a> Debug for Partition<'a>

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

Formats the value using the given formatter.