Trait kafka_protocol::protocol::Request

source ·

pub trait Request: Message + Encodable + Decodable + HeaderVersion {
    type Response: Message + Encodable + Decodable + HeaderVersion;

    const KEY: i16;
}

Expand description

An API request.

Every abstract request must be able to provide the following items:

An API key mapped to this request.
A version based on a provided header version.

Required Associated Types§

source

type Response: Message + Encodable + Decodable + HeaderVersion

The response associated with this request.

Required Associated Constants§

source

const KEY: i16

The API key of this request.

Implementors§

source §

Trait kafka_protocol::protocol::Request

Required Associated Types§

type Response: Message + Encodable + Decodable + HeaderVersion

Required Associated Constants§

const KEY: i16

Implementors§

impl Request for AddOffsetsToTxnRequest

const KEY: i16 = 25i16

type Response = AddOffsetsToTxnResponse

impl Request for AddPartitionsToTxnRequest

const KEY: i16 = 24i16

type Response = AddPartitionsToTxnResponse

impl Request for AllocateProducerIdsRequest

const KEY: i16 = 67i16

type Response = AllocateProducerIdsResponse

impl Request for AlterClientQuotasRequest

const KEY: i16 = 49i16

type Response = AlterClientQuotasResponse

impl Request for AlterConfigsRequest

const KEY: i16 = 33i16

type Response = AlterConfigsResponse

impl Request for AlterPartitionReassignmentsRequest

const KEY: i16 = 45i16

type Response = AlterPartitionReassignmentsResponse

impl Request for AlterPartitionRequest

const KEY: i16 = 56i16

type Response = AlterPartitionResponse

impl Request for AlterReplicaLogDirsRequest

const KEY: i16 = 34i16

type Response = AlterReplicaLogDirsResponse

impl Request for AlterUserScramCredentialsRequest

const KEY: i16 = 51i16

type Response = AlterUserScramCredentialsResponse

impl Request for ApiVersionsRequest

const KEY: i16 = 18i16

type Response = ApiVersionsResponse

impl Request for BeginQuorumEpochRequest

const KEY: i16 = 53i16

type Response = BeginQuorumEpochResponse

impl Request for BrokerHeartbeatRequest

const KEY: i16 = 63i16

type Response = BrokerHeartbeatResponse

impl Request for BrokerRegistrationRequest

const KEY: i16 = 62i16

type Response = BrokerRegistrationResponse

impl Request for ControlledShutdownRequest

const KEY: i16 = 7i16

type Response = ControlledShutdownResponse

impl Request for CreateAclsRequest

const KEY: i16 = 30i16

type Response = CreateAclsResponse

impl Request for CreateDelegationTokenRequest

const KEY: i16 = 38i16

type Response = CreateDelegationTokenResponse

impl Request for CreatePartitionsRequest

const KEY: i16 = 37i16

type Response = CreatePartitionsResponse

impl Request for CreateTopicsRequest

const KEY: i16 = 19i16

type Response = CreateTopicsResponse

impl Request for DeleteAclsRequest

const KEY: i16 = 31i16

type Response = DeleteAclsResponse

impl Request for DeleteGroupsRequest

const KEY: i16 = 42i16

type Response = DeleteGroupsResponse

impl Request for DeleteRecordsRequest

const KEY: i16 = 21i16

type Response = DeleteRecordsResponse

impl Request for DeleteTopicsRequest

const KEY: i16 = 20i16

type Response = DeleteTopicsResponse

impl Request for DescribeAclsRequest

const KEY: i16 = 29i16

type Response = DescribeAclsResponse

impl Request for DescribeClientQuotasRequest

const KEY: i16 = 48i16

type Response = DescribeClientQuotasResponse

impl Request for DescribeClusterRequest

const KEY: i16 = 60i16