Trait ProtocolRequest 

pub trait ProtocolRequest: Encode {
    type Response: for<'de> Decode<'de>;

    const API_KEY: i16;
    const MIN_VERSION: i16;
    const MAX_VERSION: i16;
    const LATEST_STABLE_VERSION: i16;
    const FLEXIBLE_MIN: i16;
}

Implemented by every generated Request struct in krabka-protocol.

The krabka-protocol-codegen crate emits this impl for every Request type. The trait gives the client the dispatch information it needs: the api key, the version range, and the response type.

Required Associated Constants

const API_KEY: i16

Kafka API key for this request.

const MIN_VERSION: i16

Minimum protocol version this Rust type supports.

const MAX_VERSION: i16

Maximum protocol version this Rust type can encode and decode.

This includes a version that the schema marks latestVersionUnstable, so a broker can still decode that version when it enables unstable versions. A client picks its version with Self::LATEST_STABLE_VERSION.

const LATEST_STABLE_VERSION: i16

Highest protocol version that a client can send.

This is Kafka’s ApiKeys.latestVersion(false). It is MAX_VERSION - 1 when the schema sets latestVersionUnstable, and MAX_VERSION otherwise. A value below MIN_VERSION means that the request has no stable version.

const FLEXIBLE_MIN: i16

First version that uses flexible framing from KIP-482. This is i16::MAX for never-flexible messages.

Required Associated Types

type Response: for<'de> Decode<'de>

Matching response type from krabka-protocol.

Dyn Compatibility

This trait is not dyn compatible.

In older versions of Rust, dyn compatibility was called "object safety".

Implementors

impl ProtocolRequest for AddOffsetsToTxnRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = AddOffsetsToTxnResponse

impl ProtocolRequest for AddPartitionsToTxnRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = AddPartitionsToTxnResponse

impl ProtocolRequest for AddRaftVoterRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = AddRaftVoterResponse

impl ProtocolRequest for AllocateProducerIdsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = AllocateProducerIdsResponse

impl ProtocolRequest for AlterBarrierGroupsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = MAX_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = AlterBarrierGroupsResponse

impl ProtocolRequest for AlterClientQuotasRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = AlterClientQuotasResponse

impl ProtocolRequest for AlterConfigsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = AlterConfigsResponse

impl ProtocolRequest for AlterPartitionReassignmentsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = AlterPartitionReassignmentsResponse

impl ProtocolRequest for AlterPartitionRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = AlterPartitionResponse

impl ProtocolRequest for AlterReplicaLogDirsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = AlterReplicaLogDirsResponse

impl ProtocolRequest for AlterShareGroupOffsetsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = AlterShareGroupOffsetsResponse

impl ProtocolRequest for AlterUserScramCredentialsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = AlterUserScramCredentialsResponse

impl ProtocolRequest for ApiVersionsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ApiVersionsResponse

impl ProtocolRequest for ApproveBreakGlassRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = MAX_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ApproveBreakGlassResponse

impl ProtocolRequest for AssignReplicasToDirsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = AssignReplicasToDirsResponse

impl ProtocolRequest for BeginQuorumEpochRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = BeginQuorumEpochResponse

impl ProtocolRequest for BrokerHeartbeatRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = BrokerHeartbeatResponse

impl ProtocolRequest for BrokerRegistrationRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = BrokerRegistrationResponse

impl ProtocolRequest for ConsumerGroupDescribeRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ConsumerGroupDescribeResponse

impl ProtocolRequest for ConsumerGroupHeartbeatRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ConsumerGroupHeartbeatResponse

impl ProtocolRequest for ControllerRegistrationRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ControllerRegistrationResponse

impl ProtocolRequest for CreateAclsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = CreateAclsResponse

impl ProtocolRequest for CreateDelegationTokenRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = CreateDelegationTokenResponse

impl ProtocolRequest for CreatePartitionsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = CreatePartitionsResponse

impl ProtocolRequest for CreateTopicsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = CreateTopicsResponse

impl ProtocolRequest for DeleteAclsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DeleteAclsResponse

impl ProtocolRequest for DeleteGroupsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DeleteGroupsResponse

impl ProtocolRequest for DeleteRecordsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DeleteRecordsResponse

impl ProtocolRequest for DeleteShareGroupOffsetsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DeleteShareGroupOffsetsResponse

impl ProtocolRequest for DeleteShareGroupStateRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DeleteShareGroupStateResponse

impl ProtocolRequest for DeleteTopicsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DeleteTopicsResponse

impl ProtocolRequest for DescribeAclsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeAclsResponse

impl ProtocolRequest for DescribeBarrierGroupsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = MAX_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeBarrierGroupsResponse

impl ProtocolRequest for DescribeBreakGlassRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = MAX_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeBreakGlassResponse

impl ProtocolRequest for DescribeClientQuotasRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeClientQuotasResponse

impl ProtocolRequest for DescribeClusterRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeClusterResponse

impl ProtocolRequest for DescribeConfigsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeConfigsResponse

impl ProtocolRequest for DescribeDelegationTokenRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeDelegationTokenResponse

impl ProtocolRequest for DescribeGroupsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeGroupsResponse

impl ProtocolRequest for DescribeLogDirsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeLogDirsResponse

impl ProtocolRequest for DescribeProducersRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeProducersResponse

impl ProtocolRequest for DescribeQuorumRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeQuorumResponse

impl ProtocolRequest for DescribeShareGroupOffsetsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeShareGroupOffsetsResponse

impl ProtocolRequest for DescribeTopicFreezesRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = MAX_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeTopicFreezesResponse

impl ProtocolRequest for DescribeTopicPartitionsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeTopicPartitionsResponse

impl ProtocolRequest for DescribeTransactionsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeTransactionsResponse

impl ProtocolRequest for DescribeUserScramCredentialsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = DescribeUserScramCredentialsResponse

impl ProtocolRequest for ElectLeadersRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ElectLeadersResponse

impl ProtocolRequest for EndQuorumEpochRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = EndQuorumEpochResponse

impl ProtocolRequest for EndTxnRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = EndTxnResponse

impl ProtocolRequest for EnvelopeRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = EnvelopeResponse

impl ProtocolRequest for ExpireDelegationTokenRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ExpireDelegationTokenResponse

impl ProtocolRequest for FetchRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = FetchResponse

impl ProtocolRequest for FetchRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = FetchResponse

impl ProtocolRequest for FetchSnapshotRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = FetchSnapshotResponse

impl ProtocolRequest for FindCoordinatorRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = FindCoordinatorResponse

impl ProtocolRequest for GetReplicaLogInfoRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = GetReplicaLogInfoResponse

impl ProtocolRequest for GetTelemetrySubscriptionsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = GetTelemetrySubscriptionsResponse

impl ProtocolRequest for HeartbeatRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = HeartbeatResponse

impl ProtocolRequest for IncrementalAlterConfigsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = IncrementalAlterConfigsResponse

impl ProtocolRequest for InitProducerIdRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = InitProducerIdResponse

impl ProtocolRequest for InitializeShareGroupStateRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = InitializeShareGroupStateResponse

impl ProtocolRequest for JoinGroupRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = JoinGroupResponse

impl ProtocolRequest for LeaveGroupRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = LeaveGroupResponse

impl ProtocolRequest for ListBarrierCutsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = MAX_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ListBarrierCutsResponse

impl ProtocolRequest for ListConfigResourcesRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ListConfigResourcesResponse

impl ProtocolRequest for ListGroupsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ListGroupsResponse

impl ProtocolRequest for ListOffsetsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ListOffsetsResponse

impl ProtocolRequest for ListPartitionReassignmentsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ListPartitionReassignmentsResponse

impl ProtocolRequest for ListTransactionsRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ListTransactionsResponse

impl ProtocolRequest for MetadataRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = MetadataResponse

impl ProtocolRequest for OffsetCommitRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = OffsetCommitResponse

impl ProtocolRequest for OffsetDeleteRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = OffsetDeleteResponse

impl ProtocolRequest for OffsetFetchRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = OffsetFetchResponse

impl ProtocolRequest for OffsetForLeaderEpochRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = OffsetForLeaderEpochResponse

impl ProtocolRequest for ProduceRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ProduceResponse

impl ProtocolRequest for ProduceRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ProduceResponse

impl ProtocolRequest for ProposeBreakGlassRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = MAX_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ProposeBreakGlassResponse

impl ProtocolRequest for PushTelemetryRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = PushTelemetryResponse

impl ProtocolRequest for ReadShareGroupStateRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ReadShareGroupStateResponse

impl ProtocolRequest for ReadShareGroupStateSummaryRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ReadShareGroupStateSummaryResponse

impl ProtocolRequest for RemoveRaftVoterRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = RemoveRaftVoterResponse

impl ProtocolRequest for RenewDelegationTokenRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = RenewDelegationTokenResponse

impl ProtocolRequest for SaslAuthenticateRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = SaslAuthenticateResponse

impl ProtocolRequest for SaslHandshakeRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = SaslHandshakeResponse

impl ProtocolRequest for SetTopicFreezeRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = MAX_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = SetTopicFreezeResponse

impl ProtocolRequest for ShareAcknowledgeRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ShareAcknowledgeResponse

impl ProtocolRequest for ShareFetchRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ShareFetchResponse

impl ProtocolRequest for ShareGroupDescribeRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ShareGroupDescribeResponse

impl ProtocolRequest for ShareGroupHeartbeatRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = ShareGroupHeartbeatResponse

impl ProtocolRequest for StreamsGroupDescribeRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = StreamsGroupDescribeResponse

impl ProtocolRequest for StreamsGroupHeartbeatRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = StreamsGroupHeartbeatResponse

impl ProtocolRequest for StreamsGroupTopologyDescriptionUpdateRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = StreamsGroupTopologyDescriptionUpdateResponse

impl ProtocolRequest for SyncGroupRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = SyncGroupResponse

impl ProtocolRequest for TriggerBarrierRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = MAX_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = TriggerBarrierResponse

impl ProtocolRequest for TxnOffsetCommitRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = TxnOffsetCommitResponse

impl ProtocolRequest for UnregisterBrokerRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = UnregisterBrokerResponse

impl ProtocolRequest for UnregisterControllerRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = UnregisterControllerResponse

impl ProtocolRequest for UpdateFeaturesRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = UpdateFeaturesResponse

impl ProtocolRequest for UpdateRaftVoterRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = UpdateRaftVoterResponse

impl ProtocolRequest for VoteRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = VoteResponse

impl ProtocolRequest for WriteBarrierMarkersRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = MAX_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = WriteBarrierMarkersResponse

impl ProtocolRequest for WriteShareGroupStateRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = WriteShareGroupStateResponse

impl ProtocolRequest for WriteTxnMarkersRequest

const API_KEY: i16 = API_KEY

const MIN_VERSION: i16 = MIN_VERSION

const MAX_VERSION: i16 = MAX_VERSION

const LATEST_STABLE_VERSION: i16 = LATEST_STABLE_VERSION

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

type Response = WriteTxnMarkersResponse

impl<Request, const MIN_VERSION: i16, const MAX_VERSION: i16> ProtocolRequest for VersionBoundedRequest<Request, MIN_VERSION, MAX_VERSION>

where Request: ProtocolRequest,

const API_KEY: i16 = Request::API_KEY

const MIN_VERSION: i16

const MAX_VERSION: i16

const LATEST_STABLE_VERSION: i16

const FLEXIBLE_MIN: i16 = Request::FLEXIBLE_MIN

type Response = <Request as ProtocolRequest>::Response