Struct kafka::consumer::MessageSet [−] [src]

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

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

Methods

impl<'a> MessageSet<'a>
[src]

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

fn partition(&self) -> i32

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