Skip to main content

ProtocolRequest

Trait ProtocolRequest 

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

    const API_KEY: i16;
    const MIN_VERSION: i16;
    const MAX_VERSION: i16;
    const FLEXIBLE_MIN: i16;
}
Expand description

Implemented by every generated Request struct in crabka-protocol.

The crabka-protocol-codegen crate emits this impl for every Request type. Provides the dispatch information (api key, version range, response type) that the client needs.

Required Associated Constants§

Source

const API_KEY: i16

Kafka API key for this request.

Source

const MIN_VERSION: i16

Minimum protocol version this Rust type supports.

Source

const MAX_VERSION: i16

Maximum protocol version this Rust type supports.

Source

const FLEXIBLE_MIN: i16

First version that uses flexible (KIP-482) framing. i16::MAX for never-flexible messages.

Required Associated Types§

Source

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

Matching response type from crabka-protocol.

Dyn Compatibility§

This trait is not dyn compatible.

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

Implementors§

Source§

impl ProtocolRequest for AddOffsetsToTxnRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = AddOffsetsToTxnResponse

Source§

impl ProtocolRequest for AddPartitionsToTxnRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = AddPartitionsToTxnResponse

Source§

impl ProtocolRequest for AddRaftVoterRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = AddRaftVoterResponse

Source§

impl ProtocolRequest for AllocateProducerIdsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = AllocateProducerIdsResponse

Source§

impl ProtocolRequest for AlterClientQuotasRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = AlterClientQuotasResponse

Source§

impl ProtocolRequest for AlterConfigsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = AlterConfigsResponse

Source§

impl ProtocolRequest for AlterPartitionReassignmentsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = AlterPartitionReassignmentsResponse

Source§

impl ProtocolRequest for AlterPartitionRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = AlterPartitionResponse

Source§

impl ProtocolRequest for AlterReplicaLogDirsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = AlterReplicaLogDirsResponse

Source§

impl ProtocolRequest for AlterShareGroupOffsetsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = AlterShareGroupOffsetsResponse

Source§

impl ProtocolRequest for AlterUserScramCredentialsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = AlterUserScramCredentialsResponse

Source§

impl ProtocolRequest for ApiVersionsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ApiVersionsResponse

Source§

impl ProtocolRequest for AssignReplicasToDirsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = AssignReplicasToDirsResponse

Source§

impl ProtocolRequest for BeginQuorumEpochRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = BeginQuorumEpochResponse

Source§

impl ProtocolRequest for BrokerHeartbeatRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = BrokerHeartbeatResponse

Source§

impl ProtocolRequest for BrokerRegistrationRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = BrokerRegistrationResponse

Source§

impl ProtocolRequest for ConsumerGroupDescribeRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ConsumerGroupDescribeResponse

Source§

impl ProtocolRequest for ConsumerGroupHeartbeatRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ConsumerGroupHeartbeatResponse

Source§

impl ProtocolRequest for ControllerRegistrationRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ControllerRegistrationResponse

Source§

impl ProtocolRequest for CreateAclsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = CreateAclsResponse

Source§

impl ProtocolRequest for CreateDelegationTokenRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = CreateDelegationTokenResponse

Source§

impl ProtocolRequest for CreatePartitionsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = CreatePartitionsResponse

Source§

impl ProtocolRequest for CreateTopicsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = CreateTopicsResponse

Source§

impl ProtocolRequest for DeleteAclsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DeleteAclsResponse

Source§

impl ProtocolRequest for DeleteGroupsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DeleteGroupsResponse

Source§

impl ProtocolRequest for DeleteRecordsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DeleteRecordsResponse

Source§

impl ProtocolRequest for DeleteShareGroupOffsetsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DeleteShareGroupOffsetsResponse

Source§

impl ProtocolRequest for DeleteShareGroupStateRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DeleteShareGroupStateResponse

Source§

impl ProtocolRequest for DeleteTopicsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DeleteTopicsResponse

Source§

impl ProtocolRequest for DescribeAclsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DescribeAclsResponse

Source§

impl ProtocolRequest for DescribeClientQuotasRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DescribeClientQuotasResponse

Source§

impl ProtocolRequest for DescribeClusterRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DescribeClusterResponse

Source§

impl ProtocolRequest for DescribeConfigsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DescribeConfigsResponse

Source§

impl ProtocolRequest for DescribeDelegationTokenRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DescribeDelegationTokenResponse

Source§

impl ProtocolRequest for DescribeGroupsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DescribeGroupsResponse

Source§

impl ProtocolRequest for DescribeLogDirsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DescribeLogDirsResponse

Source§

impl ProtocolRequest for DescribeProducersRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DescribeProducersResponse

Source§

impl ProtocolRequest for DescribeQuorumRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DescribeQuorumResponse

Source§

impl ProtocolRequest for DescribeShareGroupOffsetsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DescribeShareGroupOffsetsResponse

Source§

impl ProtocolRequest for DescribeTopicPartitionsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DescribeTopicPartitionsResponse

Source§

impl ProtocolRequest for DescribeTransactionsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DescribeTransactionsResponse

Source§

impl ProtocolRequest for DescribeUserScramCredentialsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = DescribeUserScramCredentialsResponse

Source§

impl ProtocolRequest for ElectLeadersRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ElectLeadersResponse

Source§

impl ProtocolRequest for EndQuorumEpochRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = EndQuorumEpochResponse

Source§

impl ProtocolRequest for EndTxnRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = EndTxnResponse

Source§

impl ProtocolRequest for EnvelopeRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = EnvelopeResponse

Source§

impl ProtocolRequest for ExpireDelegationTokenRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ExpireDelegationTokenResponse

Source§

impl ProtocolRequest for crabka_protocol::kafka_3_6_2::owned::fetch_request::FetchRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = FetchResponse

Source§

impl ProtocolRequest for crabka_protocol::owned::fetch_request::FetchRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = FetchResponse

Source§

impl ProtocolRequest for FetchSnapshotRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = FetchSnapshotResponse

Source§

impl ProtocolRequest for FindCoordinatorRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = FindCoordinatorResponse

Source§

impl ProtocolRequest for GetReplicaLogInfoRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = GetReplicaLogInfoResponse

Source§

impl ProtocolRequest for GetTelemetrySubscriptionsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = GetTelemetrySubscriptionsResponse

Source§

impl ProtocolRequest for HeartbeatRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = HeartbeatResponse

Source§

impl ProtocolRequest for IncrementalAlterConfigsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = IncrementalAlterConfigsResponse

Source§

impl ProtocolRequest for InitProducerIdRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = InitProducerIdResponse

Source§

impl ProtocolRequest for InitializeShareGroupStateRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = InitializeShareGroupStateResponse

Source§

impl ProtocolRequest for JoinGroupRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = JoinGroupResponse

Source§

impl ProtocolRequest for LeaveGroupRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = LeaveGroupResponse

Source§

impl ProtocolRequest for ListConfigResourcesRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ListConfigResourcesResponse

Source§

impl ProtocolRequest for ListGroupsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ListGroupsResponse

Source§

impl ProtocolRequest for ListOffsetsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ListOffsetsResponse

Source§

impl ProtocolRequest for ListPartitionReassignmentsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ListPartitionReassignmentsResponse

Source§

impl ProtocolRequest for ListTransactionsRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ListTransactionsResponse

Source§

impl ProtocolRequest for MetadataRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = MetadataResponse

Source§

impl ProtocolRequest for OffsetCommitRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = OffsetCommitResponse

Source§

impl ProtocolRequest for OffsetDeleteRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = OffsetDeleteResponse

Source§

impl ProtocolRequest for OffsetFetchRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = OffsetFetchResponse

Source§

impl ProtocolRequest for OffsetForLeaderEpochRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = OffsetForLeaderEpochResponse

Source§

impl ProtocolRequest for crabka_protocol::kafka_3_6_2::owned::produce_request::ProduceRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ProduceResponse

Source§

impl ProtocolRequest for crabka_protocol::owned::produce_request::ProduceRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ProduceResponse

Source§

impl ProtocolRequest for PushTelemetryRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = PushTelemetryResponse

Source§

impl ProtocolRequest for ReadShareGroupStateRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ReadShareGroupStateResponse

Source§

impl ProtocolRequest for ReadShareGroupStateSummaryRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ReadShareGroupStateSummaryResponse

Source§

impl ProtocolRequest for RemoveRaftVoterRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = RemoveRaftVoterResponse

Source§

impl ProtocolRequest for RenewDelegationTokenRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = RenewDelegationTokenResponse

Source§

impl ProtocolRequest for SaslAuthenticateRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = SaslAuthenticateResponse

Source§

impl ProtocolRequest for SaslHandshakeRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = SaslHandshakeResponse

Source§

impl ProtocolRequest for ShareAcknowledgeRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ShareAcknowledgeResponse

Source§

impl ProtocolRequest for ShareFetchRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ShareFetchResponse

Source§

impl ProtocolRequest for ShareGroupDescribeRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ShareGroupDescribeResponse

Source§

impl ProtocolRequest for ShareGroupHeartbeatRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = ShareGroupHeartbeatResponse

Source§

impl ProtocolRequest for StreamsGroupDescribeRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = StreamsGroupDescribeResponse

Source§

impl ProtocolRequest for StreamsGroupHeartbeatRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = StreamsGroupHeartbeatResponse

Source§

impl ProtocolRequest for SyncGroupRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = SyncGroupResponse

Source§

impl ProtocolRequest for TxnOffsetCommitRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = TxnOffsetCommitResponse

Source§

impl ProtocolRequest for UnregisterBrokerRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = UnregisterBrokerResponse

Source§

impl ProtocolRequest for UpdateFeaturesRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = UpdateFeaturesResponse

Source§

impl ProtocolRequest for UpdateRaftVoterRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = UpdateRaftVoterResponse

Source§

impl ProtocolRequest for VoteRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = VoteResponse

Source§

impl ProtocolRequest for WriteShareGroupStateRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = WriteShareGroupStateResponse

Source§

impl ProtocolRequest for WriteTxnMarkersRequest

Source§

const API_KEY: i16 = API_KEY

Source§

const MIN_VERSION: i16 = MIN_VERSION

Source§

const MAX_VERSION: i16 = MAX_VERSION

Source§

const FLEXIBLE_MIN: i16 = FLEXIBLE_MIN

Source§

type Response = WriteTxnMarkersResponse