Struct kafka::client::CommitOffset

pub struct CommitOffset<'a> {
    pub offset: i64,
    pub topic: &'a str,
    pub partition: i32,
}

Data point identifying a particular topic partition offset to be commited. See KafkaClient::commit_offsets.

Fields

offset: i64

The offset to be committed

topic: &'a str

The topic to commit the offset for

partition: i32

The partition to commit the offset for

Methods

impl<'a> CommitOffset<'a>

pub fn new(topic: &'a str, partition: i32, offset: i64) -> Self

Trait Implementations

impl<'a> AsRef<CommitOffset<'a>> for CommitOffset<'a>

fn as_ref(&self) -> &Self

Performs the conversion.

impl<'a> Debug for CommitOffset<'a>

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

Formats the value using the given formatter.