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. The Error type, a wrapper around a dynamic error type.
• EncodeError
  An error representing any fault while encoding a message, usually when a message in an invalid state is attempted to be encoded. The Error type, a wrapper around a dynamic error type.
• StrBytes
  A string type backed by Bytes.
• 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.