Module kafka_protocol::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

• Builder
  Every protocol item implements [derive_builder::Builder], which can be created using Default::default or retrieved via this trait.
• 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 Aliases

• StrBytes
  A string type backed by bytes::Bytes.