Struct MessageSets

pub struct MessageSets { /* private fields */ }

Messages retrieved from kafka in one fetch request. This is a concatenation of blocks of messages successfully retrieved from the consumed topic partitions. Each such partitions is guaranteed to be present at most once in this structure.

Implementations

impl MessageSets

pub fn is_empty(&self) -> bool

Determines efficiently whether there are any consumeable messages in this data set.

pub fn iter(&self) -> MessageSetsIter<'_>

Iterates over the message sets delivering the fetched message data of consumed topic partitions.

Trait Implementations

impl Debug for MessageSets

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

Formats the value using the given formatter.