Struct kafka_offsets_parser::OffsetCommitValue

pub struct OffsetCommitValue<'a> {
    pub version: u16,
    pub offset: u64,
    pub leader_epoch: Option<u32>,
    pub commit_timestamp: u64,
    pub expire_timestamp: Option<u64>,
    // some fields omitted
}

Message value when key is an OffsetKey

Fields

version: u16

offset: u64

leader_epoch: Option<u32>

commit_timestamp: u64

expire_timestamp: Option<u64>

Implementations

impl<'a> OffsetCommitValue<'a>

pub fn metadata(&self) -> &str

Trait Implementations

impl<'a> Clone for OffsetCommitValue<'a>

fn clone(&self) -> OffsetCommitValue<'a>

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<'a> Debug for OffsetCommitValue<'a>

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

Formats the value using the given formatter.

impl<'a> TryFrom<&'a [u8]> for OffsetCommitValue<'a>

type Error = ConsumerOffsetsMessageParseError<&'a [u8]>

The type returned in the event of a conversion error.

fn try_from(bytes: &'a [u8]) -> Result<Self, Self::Error>

Performs the conversion.