Struct PolledMessages

pub struct PolledMessages {
    pub partition_id: u32,
    pub current_offset: u64,
    pub messages: Vec<PolledMessage>,
}

The wrapper on top of the collection of messages that are polled from the partition. It consists of the following fields:

• partition_id: the identifier of the partition.
• current_offset: the current offset of the partition.
• messages: the collection of messages.

Fields

partition_id: u32

The identifier of the partition. If it’s ‘0’, then there’s no partition assigned to the consumer group member.

current_offset: u64

The current offset of the partition.

messages: Vec<PolledMessage>

The collection of messages.

Trait Implementations

impl Debug for PolledMessages

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

Formats the value using the given formatter.

impl<'de> Deserialize<'de> for PolledMessages

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Serialize for PolledMessages

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.