Struct 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 committed. 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

Implementations

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

Converts this type into a shared reference of the (usually inferred) input type.

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

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

Formats the value using the given formatter.