Module kafka_protocol::protocol

Raw types and utilities for use with the Kafka protocol.

Most types are used internally in encoding/decoding, and are not required by typical use cases for interacting with the protocol. However, types can be used for decoding partial messages, or rewriting parts of an encoded message.

Modules

buf

Utilities for working with the bytes crate.

types

Raw types of the Kafka protocol, as defined by the protocol specification.

Structs

DecodeError

An error representing any fault while decoding a message, usually when the buffer is incorrectly sized or otherwise invalid for the decoded message.

EncodeError

An error representing any fault while encoding a message, usually when a message in an invalid state is attempted to be encoded.

VersionRange

The range of versions (min, max) allowed for agiven message.

Traits

Decodable

A decodable message.

Encodable

An encodable message.

HeaderVersion

Every message has a set of versions valid for a given header version.

Message

An API request or response.

Request

An API request.

Type Definitions

StrBytes

A string type backed by bytes::Bytes.