Struct kafka::consumer::MessageSet

pub struct MessageSet<'a> { /* fields omitted */ }

A set of messages succesfully retrieved from a specific topic partition.

Methods

impl<'a> MessageSet<'a>

fn topic(&self) -> &'a str

fn partition(&self) -> i32

fn messages(&self) -> &'a [Message<'a>]