Enum kafka_offsets_parser::ConsumerOffsetsMessageKey

pub enum ConsumerOffsetsMessageKey<'a> {
    Offset(OffsetKey<'a>),
    GroupMetadata,
}

The message key for messages on the __consumer_offsets topic

Variants

Offset(OffsetKey<'a>)

Key for OffsetCommitValue message

Tuple Fields of Offset

0: OffsetKey<'a>

GroupMetadata

Key for a GroupMetadata message.

We don’t actually parse this key, but since it’s a possible variant we include a tag here so it can be handled properly vs inspecting errors to check if parsing failed because we haven’t implemented this key type.

Trait Implementations

impl<'a> Clone for ConsumerOffsetsMessageKey<'a>

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

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<'a> Debug for ConsumerOffsetsMessageKey<'a>

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

Formats the value using the given formatter.

impl<'a> TryFrom<&'a [u8]> for ConsumerOffsetsMessageKey<'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.