Struct Partition

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

The result of a “fetch messages” request from a particular Kafka broker for a single topic partition only. Beside the partition identifier, this structure provides an iterator over the actually requested message data.

Note: There might have been a (recoverable) error for a particular partition (but not for another).

Implementations

impl<'a> Partition<'a>

pub fn partition(&self) -> i32

Retrieves the identifier of the represented partition.

pub fn data(&'a self) -> Result<&'a Data<'a>, Arc<Error>>

Retrieves the data payload for this partition.

Trait Implementations

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

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

Formats the value using the given formatter.