Trait RequestBody 

pub trait RequestBody {
    type ResponseBody;

    const API_KEY: ApiKey;
    const API_VERSION_RANGE: ApiVersionRange;
    const FIRST_TAGGED_FIELD_IN_REQUEST_VERSION: ApiVersion;
    const FIRST_TAGGED_FIELD_IN_RESPONSE_VERSION: ApiVersion = Self::FIRST_TAGGED_FIELD_IN_REQUEST_VERSION;
}

Specifies a request body.

Required Associated Constants

const API_KEY: ApiKey

Kafka API key.

This will be added to the request header.

const API_VERSION_RANGE: ApiVersionRange

Supported version range.

From this range and the range that the broker reports, we will pick the highest version that both support.

const FIRST_TAGGED_FIELD_IN_REQUEST_VERSION: ApiVersion

The first version of the messages (not of the header) that uses tagged fields, if any.

To determine the version just look for the _tagged_fields or TAG_BUFFER in the protocol description.

This will be used to control which request and response header versions will be used.

It’s OK to specify a version here that is larger then the highest supported version.

Provided Associated Constants

const FIRST_TAGGED_FIELD_IN_RESPONSE_VERSION: ApiVersion = Self::FIRST_TAGGED_FIELD_IN_REQUEST_VERSION

Normally the same as FIRST_TAGGED_FIELD_IN_REQUEST_VERSION but there are some special snowflakes.

Required Associated Types

type ResponseBody

The response type that will follow when issuing this request.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety", so this trait is not object safe.

Implementations on Foreign Types

impl<T: RequestBody> RequestBody for &T

const API_KEY: ApiKey = T::API_KEY

const API_VERSION_RANGE: ApiVersionRange = T::API_VERSION_RANGE

const FIRST_TAGGED_FIELD_IN_REQUEST_VERSION: ApiVersion = T::FIRST_TAGGED_FIELD_IN_REQUEST_VERSION

const FIRST_TAGGED_FIELD_IN_RESPONSE_VERSION: ApiVersion = T::FIRST_TAGGED_FIELD_IN_RESPONSE_VERSION

type ResponseBody = <T as RequestBody>::ResponseBody

Implementors

impl RequestBody for ApiVersionsRequest

const API_KEY: ApiKey = ApiKey::ApiVersions

const API_VERSION_RANGE: ApiVersionRange

const FIRST_TAGGED_FIELD_IN_REQUEST_VERSION: ApiVersion

const FIRST_TAGGED_FIELD_IN_RESPONSE_VERSION: ApiVersion

type ResponseBody = ApiVersionsResponse

impl RequestBody for CreateTopicsRequest

const API_KEY: ApiKey = ApiKey::CreateTopics

const API_VERSION_RANGE: ApiVersionRange

const FIRST_TAGGED_FIELD_IN_REQUEST_VERSION: ApiVersion

type ResponseBody = CreateTopicsResponse

impl RequestBody for DeleteRecordsRequest

const API_KEY: ApiKey = ApiKey::DeleteRecords

const API_VERSION_RANGE: ApiVersionRange

const FIRST_TAGGED_FIELD_IN_REQUEST_VERSION: ApiVersion

type ResponseBody = DeleteRecordsResponse

impl RequestBody for DeleteTopicsRequest

const API_KEY: ApiKey = ApiKey::DeleteTopics

const API_VERSION_RANGE: ApiVersionRange

const FIRST_TAGGED_FIELD_IN_REQUEST_VERSION: ApiVersion

type ResponseBody = DeleteTopicsResponse

impl RequestBody for FetchRequest

const API_KEY: ApiKey = ApiKey::Fetch

const API_VERSION_RANGE: ApiVersionRange

const FIRST_TAGGED_FIELD_IN_REQUEST_VERSION: ApiVersion

type ResponseBody = FetchResponse

impl RequestBody for ListOffsetsRequest

const API_KEY: ApiKey = ApiKey::ListOffsets

const API_VERSION_RANGE: ApiVersionRange

const FIRST_TAGGED_FIELD_IN_REQUEST_VERSION: ApiVersion

type ResponseBody = ListOffsetsResponse

impl RequestBody for MetadataRequest

const API_KEY: ApiKey = ApiKey::Metadata

const API_VERSION_RANGE: ApiVersionRange

const FIRST_TAGGED_FIELD_IN_REQUEST_VERSION: ApiVersion

type ResponseBody = MetadataResponse

impl RequestBody for ProduceRequest

const API_KEY: ApiKey = ApiKey::Produce

const API_VERSION_RANGE: ApiVersionRange

const FIRST_TAGGED_FIELD_IN_REQUEST_VERSION: ApiVersion

type ResponseBody = ProduceResponse