konsumer_offsets 0.1.0

A library crate to parse the content of the Kafka `__consumer_offsets` internal topic
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41

use bytes_parser::BytesParserError;
use thiserror::Error;

/// Errors variants that can be encountered when parsing of `__consumer_offsets` messages.
#[derive(Error, Debug, Eq, PartialEq)]
pub enum KonsumerOffsetsError {
    /// The message contains no key, making parsing of the rest of the message impossible.
    ///
    /// The message key contains information to determine the version of the message, on which
    /// the rest of the parsing logic depends.
    #[error("Cannot parse message without its key: unable to determine version")]
    MessageKeyMissing,

    /// An error occurred during parsing.
    #[error("Failure while parsing bytes: {0}")]
    ByteParsingError(#[source] BytesParserError),

    /// Message key refers to a version format which this crate doesn't currently support.
    #[error("Encountered a not (yet) supported message version: {0}")]
    UnsupportedMessageVersion(i16),

    /// Message payload for an [`crate::offset_commit::OffsetCommit`] refers to a schema format which this crate doesn't currently support.
    #[error("Encountered a not (yet) supported schema version for offset commit: {0}")]
    UnsupportedOffsetCommitSchema(i16),

    /// Message payload for a [`crate::group_metadata::GroupMetadata`] refers to a schema format which this crate doesn't currently support.
    #[error("Encountered a not (yet) supported schema version for group metadata: {0}")]
    UnsupportedGroupMetadataSchema(i16),

    /// Message payload for a [`crate::group_metadata::ConsumerProtocolSubscription`] refers to a version format which this crate doesn't currently support.
    #[error("Encountered a not (yet) supported consumer protocol subscription version: {0}")]
    UnsupportedConsumerProtocolSubscriptionVersion(i16),

    /// Message payload for a [`crate::group_metadata::ConsumerProtocolAssignment`] refers to a version format which this crate doesn't currently support.
    #[error("Encountered a not (yet) supported consumer protocol assignment version: {0}")]
    UnsupportedConsumerProtocolAssignmentVersion(i16),

    /// A value of a given type cannot be parsed for a specific version of another type.
    #[error("Unable to parse {0} for version {1} of {2}")]
    UnableToParseForVersion(String, i16, String),
}