Enum RequestKind

#[non_exhaustive]
pub enum RequestKind {
    Produce(ProduceRequest),
    Fetch(FetchRequest),
    ListOffsets(ListOffsetsRequest),
    Metadata(MetadataRequest),
    LeaderAndIsr(LeaderAndIsrRequest),
    StopReplica(StopReplicaRequest),
    UpdateMetadata(UpdateMetadataRequest),
    ControlledShutdown(ControlledShutdownRequest),
    OffsetCommit(OffsetCommitRequest),
    OffsetFetch(OffsetFetchRequest),
    FindCoordinator(FindCoordinatorRequest),
    JoinGroup(JoinGroupRequest),
    Heartbeat(HeartbeatRequest),
    LeaveGroup(LeaveGroupRequest),
    SyncGroup(SyncGroupRequest),
    DescribeGroups(DescribeGroupsRequest),
    ListGroups(ListGroupsRequest),
    SaslHandshake(SaslHandshakeRequest),
    ApiVersions(ApiVersionsRequest),
    CreateTopics(CreateTopicsRequest),
    DeleteTopics(DeleteTopicsRequest),
    DeleteRecords(DeleteRecordsRequest),
    InitProducerId(InitProducerIdRequest),
    OffsetForLeaderEpoch(OffsetForLeaderEpochRequest),
    AddPartitionsToTxn(AddPartitionsToTxnRequest),
    AddOffsetsToTxn(AddOffsetsToTxnRequest),
    EndTxn(EndTxnRequest),
    WriteTxnMarkers(WriteTxnMarkersRequest),
    TxnOffsetCommit(TxnOffsetCommitRequest),
    DescribeAcls(DescribeAclsRequest),
    CreateAcls(CreateAclsRequest),
    DeleteAcls(DeleteAclsRequest),
    DescribeConfigs(DescribeConfigsRequest),
    AlterConfigs(AlterConfigsRequest),
    AlterReplicaLogDirs(AlterReplicaLogDirsRequest),
    DescribeLogDirs(DescribeLogDirsRequest),
    SaslAuthenticate(SaslAuthenticateRequest),
    CreatePartitions(CreatePartitionsRequest),
    CreateDelegationToken(CreateDelegationTokenRequest),
    RenewDelegationToken(RenewDelegationTokenRequest),
    ExpireDelegationToken(ExpireDelegationTokenRequest),
    DescribeDelegationToken(DescribeDelegationTokenRequest),
    DeleteGroups(DeleteGroupsRequest),
    ElectLeaders(ElectLeadersRequest),
    IncrementalAlterConfigs(IncrementalAlterConfigsRequest),
    AlterPartitionReassignments(AlterPartitionReassignmentsRequest),
    ListPartitionReassignments(ListPartitionReassignmentsRequest),
    OffsetDelete(OffsetDeleteRequest),
    DescribeClientQuotas(DescribeClientQuotasRequest),
    AlterClientQuotas(AlterClientQuotasRequest),
    DescribeUserScramCredentials(DescribeUserScramCredentialsRequest),
    AlterUserScramCredentials(AlterUserScramCredentialsRequest),
    Vote(VoteRequest),
    BeginQuorumEpoch(BeginQuorumEpochRequest),
    EndQuorumEpoch(EndQuorumEpochRequest),
    DescribeQuorum(DescribeQuorumRequest),
    AlterPartition(AlterPartitionRequest),
    UpdateFeatures(UpdateFeaturesRequest),
    Envelope(EnvelopeRequest),
    FetchSnapshot(FetchSnapshotRequest),
    DescribeCluster(DescribeClusterRequest),
    DescribeProducers(DescribeProducersRequest),
    BrokerRegistration(BrokerRegistrationRequest),
    BrokerHeartbeat(BrokerHeartbeatRequest),
    UnregisterBroker(UnregisterBrokerRequest),
    DescribeTransactions(DescribeTransactionsRequest),
    ListTransactions(ListTransactionsRequest),
    AllocateProducerIds(AllocateProducerIdsRequest),
    ConsumerGroupHeartbeat(ConsumerGroupHeartbeatRequest),
    ConsumerGroupDescribe(ConsumerGroupDescribeRequest),
    ControllerRegistration(ControllerRegistrationRequest),
    GetTelemetrySubscriptions(GetTelemetrySubscriptionsRequest),
    PushTelemetry(PushTelemetryRequest),
    AssignReplicasToDirs(AssignReplicasToDirsRequest),
    ListClientMetricsResources(ListClientMetricsResourcesRequest),
    DescribeTopicPartitions(DescribeTopicPartitionsRequest),
}

Available on crate feature messages_enums only.

Wrapping enum for all requests in the Kafka protocol.

Variants (Non-exhaustive)

Non-exhaustive enums could have additional variants added in future. Therefore, when matching against variants of non-exhaustive enums, an extra wildcard arm must be added to account for any future variants.

Produce(ProduceRequest)

ProduceRequest,

Fetch(FetchRequest)

FetchRequest,

ListOffsets(ListOffsetsRequest)

ListOffsetsRequest,

Metadata(MetadataRequest)

MetadataRequest,

LeaderAndIsr(LeaderAndIsrRequest)

LeaderAndIsrRequest,

StopReplica(StopReplicaRequest)

StopReplicaRequest,

UpdateMetadata(UpdateMetadataRequest)

UpdateMetadataRequest,

ControlledShutdown(ControlledShutdownRequest)

ControlledShutdownRequest,

OffsetCommit(OffsetCommitRequest)

OffsetCommitRequest,

OffsetFetch(OffsetFetchRequest)

OffsetFetchRequest,

FindCoordinator(FindCoordinatorRequest)

FindCoordinatorRequest,

JoinGroup(JoinGroupRequest)

JoinGroupRequest,

Heartbeat(HeartbeatRequest)

HeartbeatRequest,

LeaveGroup(LeaveGroupRequest)

LeaveGroupRequest,

SyncGroup(SyncGroupRequest)

SyncGroupRequest,

DescribeGroups(DescribeGroupsRequest)

DescribeGroupsRequest,

ListGroups(ListGroupsRequest)

ListGroupsRequest,

SaslHandshake(SaslHandshakeRequest)

SaslHandshakeRequest,

ApiVersions(ApiVersionsRequest)

ApiVersionsRequest,

CreateTopics(CreateTopicsRequest)

CreateTopicsRequest,

DeleteTopics(DeleteTopicsRequest)

DeleteTopicsRequest,

DeleteRecords(DeleteRecordsRequest)

DeleteRecordsRequest,

InitProducerId(InitProducerIdRequest)

InitProducerIdRequest,

OffsetForLeaderEpoch(OffsetForLeaderEpochRequest)

OffsetForLeaderEpochRequest,

AddPartitionsToTxn(AddPartitionsToTxnRequest)

AddPartitionsToTxnRequest,

AddOffsetsToTxn(AddOffsetsToTxnRequest)

AddOffsetsToTxnRequest,

EndTxn(EndTxnRequest)

EndTxnRequest,

WriteTxnMarkers(WriteTxnMarkersRequest)

WriteTxnMarkersRequest,

TxnOffsetCommit(TxnOffsetCommitRequest)

TxnOffsetCommitRequest,

DescribeAcls(DescribeAclsRequest)

DescribeAclsRequest,

CreateAcls(CreateAclsRequest)

CreateAclsRequest,

DeleteAcls(DeleteAclsRequest)

DeleteAclsRequest,

DescribeConfigs(DescribeConfigsRequest)

DescribeConfigsRequest,

AlterConfigs(AlterConfigsRequest)

AlterConfigsRequest,

AlterReplicaLogDirs(AlterReplicaLogDirsRequest)

AlterReplicaLogDirsRequest,

DescribeLogDirs(DescribeLogDirsRequest)

DescribeLogDirsRequest,

SaslAuthenticate(SaslAuthenticateRequest)

SaslAuthenticateRequest,

CreatePartitions(CreatePartitionsRequest)

CreatePartitionsRequest,

CreateDelegationToken(CreateDelegationTokenRequest)

CreateDelegationTokenRequest,

RenewDelegationToken(RenewDelegationTokenRequest)

RenewDelegationTokenRequest,

ExpireDelegationToken(ExpireDelegationTokenRequest)

ExpireDelegationTokenRequest,

DescribeDelegationToken(DescribeDelegationTokenRequest)

DescribeDelegationTokenRequest,

DeleteGroups(DeleteGroupsRequest)

DeleteGroupsRequest,

ElectLeaders(ElectLeadersRequest)

ElectLeadersRequest,

IncrementalAlterConfigs(IncrementalAlterConfigsRequest)

IncrementalAlterConfigsRequest,

AlterPartitionReassignments(AlterPartitionReassignmentsRequest)

AlterPartitionReassignmentsRequest,

ListPartitionReassignments(ListPartitionReassignmentsRequest)

ListPartitionReassignmentsRequest,

OffsetDelete(OffsetDeleteRequest)

OffsetDeleteRequest,

DescribeClientQuotas(DescribeClientQuotasRequest)

DescribeClientQuotasRequest,

AlterClientQuotas(AlterClientQuotasRequest)

AlterClientQuotasRequest,

DescribeUserScramCredentials(DescribeUserScramCredentialsRequest)

DescribeUserScramCredentialsRequest,

AlterUserScramCredentials(AlterUserScramCredentialsRequest)

AlterUserScramCredentialsRequest,

Vote(VoteRequest)

VoteRequest,

BeginQuorumEpoch(BeginQuorumEpochRequest)

BeginQuorumEpochRequest,

EndQuorumEpoch(EndQuorumEpochRequest)

EndQuorumEpochRequest,

DescribeQuorum(DescribeQuorumRequest)

DescribeQuorumRequest,

AlterPartition(AlterPartitionRequest)

AlterPartitionRequest,

UpdateFeatures(UpdateFeaturesRequest)

UpdateFeaturesRequest,

Envelope(EnvelopeRequest)

EnvelopeRequest,

FetchSnapshot(FetchSnapshotRequest)

FetchSnapshotRequest,

DescribeCluster(DescribeClusterRequest)

DescribeClusterRequest,

DescribeProducers(DescribeProducersRequest)

DescribeProducersRequest,

BrokerRegistration(BrokerRegistrationRequest)

BrokerRegistrationRequest,

BrokerHeartbeat(BrokerHeartbeatRequest)

BrokerHeartbeatRequest,

UnregisterBroker(UnregisterBrokerRequest)

UnregisterBrokerRequest,

DescribeTransactions(DescribeTransactionsRequest)

DescribeTransactionsRequest,

ListTransactions(ListTransactionsRequest)

ListTransactionsRequest,

AllocateProducerIds(AllocateProducerIdsRequest)

AllocateProducerIdsRequest,

ConsumerGroupHeartbeat(ConsumerGroupHeartbeatRequest)

ConsumerGroupHeartbeatRequest,

ConsumerGroupDescribe(ConsumerGroupDescribeRequest)

ConsumerGroupDescribeRequest,

ControllerRegistration(ControllerRegistrationRequest)

ControllerRegistrationRequest,

GetTelemetrySubscriptions(GetTelemetrySubscriptionsRequest)

GetTelemetrySubscriptionsRequest,

PushTelemetry(PushTelemetryRequest)

PushTelemetryRequest,

AssignReplicasToDirs(AssignReplicasToDirsRequest)

AssignReplicasToDirsRequest,

ListClientMetricsResources(ListClientMetricsResourcesRequest)

ListClientMetricsResourcesRequest,

DescribeTopicPartitions(DescribeTopicPartitionsRequest)

DescribeTopicPartitionsRequest,

Implementations

impl RequestKind

pub fn encode(&self, bytes: &mut BytesMut, version: i16) -> Result<()>

Available on crate feature client only.

Encode the message into the target buffer

pub fn decode( api_key: ApiKey, bytes: &mut Bytes, version: i16, ) -> Result<RequestKind>

Available on crate feature broker only.

Decode the message from the provided buffer and version

Trait Implementations

impl Clone for RequestKind

fn clone(&self) -> RequestKind

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for RequestKind

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl From<AddOffsetsToTxnRequest> for RequestKind

fn from(value: AddOffsetsToTxnRequest) -> RequestKind

Converts to this type from the input type.

impl From<AddPartitionsToTxnRequest> for RequestKind

fn from(value: AddPartitionsToTxnRequest) -> RequestKind

Converts to this type from the input type.

impl From<AllocateProducerIdsRequest> for RequestKind

fn from(value: AllocateProducerIdsRequest) -> RequestKind

Converts to this type from the input type.

impl From<AlterClientQuotasRequest> for RequestKind

fn from(value: AlterClientQuotasRequest) -> RequestKind

Converts to this type from the input type.

impl From<AlterConfigsRequest> for RequestKind

fn from(value: AlterConfigsRequest) -> RequestKind

Converts to this type from the input type.

impl From<AlterPartitionReassignmentsRequest> for RequestKind

fn from(value: AlterPartitionReassignmentsRequest) -> RequestKind

Converts to this type from the input type.

impl From<AlterPartitionRequest> for RequestKind

fn from(value: AlterPartitionRequest) -> RequestKind

Converts to this type from the input type.

impl From<AlterReplicaLogDirsRequest> for RequestKind

fn from(value: AlterReplicaLogDirsRequest) -> RequestKind

Converts to this type from the input type.

impl From<AlterUserScramCredentialsRequest> for RequestKind

fn from(value: AlterUserScramCredentialsRequest) -> RequestKind

Converts to this type from the input type.

impl From<ApiVersionsRequest> for RequestKind

fn from(value: ApiVersionsRequest) -> RequestKind

Converts to this type from the input type.

impl From<AssignReplicasToDirsRequest> for RequestKind

fn from(value: AssignReplicasToDirsRequest) -> RequestKind

Converts to this type from the input type.

impl From<BeginQuorumEpochRequest> for RequestKind

fn from(value: BeginQuorumEpochRequest) -> RequestKind

Converts to this type from the input type.

impl From<BrokerHeartbeatRequest> for RequestKind

fn from(value: BrokerHeartbeatRequest) -> RequestKind

Converts to this type from the input type.

impl From<BrokerRegistrationRequest> for RequestKind

fn from(value: BrokerRegistrationRequest) -> RequestKind

Converts to this type from the input type.

impl From<ConsumerGroupDescribeRequest> for RequestKind

fn from(value: ConsumerGroupDescribeRequest) -> RequestKind

Converts to this type from the input type.

impl From<ConsumerGroupHeartbeatRequest> for RequestKind

fn from(value: ConsumerGroupHeartbeatRequest) -> RequestKind

Converts to this type from the input type.

impl From<ControlledShutdownRequest> for RequestKind

fn from(value: ControlledShutdownRequest) -> RequestKind

Converts to this type from the input type.

impl From<ControllerRegistrationRequest> for RequestKind

fn from(value: ControllerRegistrationRequest) -> RequestKind

Converts to this type from the input type.

impl From<CreateAclsRequest> for RequestKind

fn from(value: CreateAclsRequest) -> RequestKind

Converts to this type from the input type.

impl From<CreateDelegationTokenRequest> for RequestKind

fn from(value: CreateDelegationTokenRequest) -> RequestKind

Converts to this type from the input type.

impl From<CreatePartitionsRequest> for RequestKind

fn from(value: CreatePartitionsRequest) -> RequestKind

Converts to this type from the input type.

impl From<CreateTopicsRequest> for RequestKind

fn from(value: CreateTopicsRequest) -> RequestKind

Converts to this type from the input type.

impl From<DeleteAclsRequest> for RequestKind

fn from(value: DeleteAclsRequest) -> RequestKind

Converts to this type from the input type.

impl From<DeleteGroupsRequest> for RequestKind

fn from(value: DeleteGroupsRequest) -> RequestKind

Converts to this type from the input type.

impl From<DeleteRecordsRequest> for RequestKind

fn from(value: DeleteRecordsRequest) -> RequestKind

Converts to this type from the input type.

impl From<DeleteTopicsRequest> for RequestKind

fn from(value: DeleteTopicsRequest) -> RequestKind

Converts to this type from the input type.

impl From<DescribeAclsRequest> for RequestKind

fn from(value: DescribeAclsRequest) -> RequestKind

Converts to this type from the input type.

impl From<DescribeClientQuotasRequest> for RequestKind

fn from(value: DescribeClientQuotasRequest) -> RequestKind

Converts to this type from the input type.

impl From<DescribeClusterRequest> for RequestKind

fn from(value: DescribeClusterRequest) -> RequestKind

Converts to this type from the input type.

impl From<DescribeConfigsRequest> for RequestKind

fn from(value: DescribeConfigsRequest) -> RequestKind

Converts to this type from the input type.

impl From<DescribeDelegationTokenRequest> for RequestKind

fn from(value: DescribeDelegationTokenRequest) -> RequestKind

Converts to this type from the input type.

impl From<DescribeGroupsRequest> for RequestKind

fn from(value: DescribeGroupsRequest) -> RequestKind

Converts to this type from the input type.

impl From<DescribeLogDirsRequest> for RequestKind

fn from(value: DescribeLogDirsRequest) -> RequestKind

Converts to this type from the input type.

impl From<DescribeProducersRequest> for RequestKind

fn from(value: DescribeProducersRequest) -> RequestKind

Converts to this type from the input type.

impl From<DescribeQuorumRequest> for RequestKind

fn from(value: DescribeQuorumRequest) -> RequestKind

Converts to this type from the input type.

impl From<DescribeTopicPartitionsRequest> for RequestKind

fn from(value: DescribeTopicPartitionsRequest) -> RequestKind

Converts to this type from the input type.

impl From<DescribeTransactionsRequest> for RequestKind

fn from(value: DescribeTransactionsRequest) -> RequestKind

Converts to this type from the input type.

impl From<DescribeUserScramCredentialsRequest> for RequestKind

fn from(value: DescribeUserScramCredentialsRequest) -> RequestKind

Converts to this type from the input type.

impl From<ElectLeadersRequest> for RequestKind

fn from(value: ElectLeadersRequest) -> RequestKind

Converts to this type from the input type.

impl From<EndQuorumEpochRequest> for RequestKind

fn from(value: EndQuorumEpochRequest) -> RequestKind

Converts to this type from the input type.

impl From<EndTxnRequest> for RequestKind

fn from(value: EndTxnRequest) -> RequestKind

Converts to this type from the input type.

impl From<EnvelopeRequest> for RequestKind

fn from(value: EnvelopeRequest) -> RequestKind

Converts to this type from the input type.

impl From<ExpireDelegationTokenRequest> for RequestKind

fn from(value: ExpireDelegationTokenRequest) -> RequestKind

Converts to this type from the input type.

impl From<FetchRequest> for RequestKind

fn from(value: FetchRequest) -> RequestKind

Converts to this type from the input type.

impl From<FetchSnapshotRequest> for RequestKind

fn from(value: FetchSnapshotRequest) -> RequestKind

Converts to this type from the input type.

impl From<FindCoordinatorRequest> for RequestKind

fn from(value: FindCoordinatorRequest) -> RequestKind

Converts to this type from the input type.

impl From<GetTelemetrySubscriptionsRequest> for RequestKind

fn from(value: GetTelemetrySubscriptionsRequest) -> RequestKind

Converts to this type from the input type.

impl From<HeartbeatRequest> for RequestKind

fn from(value: HeartbeatRequest) -> RequestKind

Converts to this type from the input type.

impl From<IncrementalAlterConfigsRequest> for RequestKind

fn from(value: IncrementalAlterConfigsRequest) -> RequestKind

Converts to this type from the input type.

impl From<InitProducerIdRequest> for RequestKind

fn from(value: InitProducerIdRequest) -> RequestKind

Converts to this type from the input type.

impl From<JoinGroupRequest> for RequestKind

fn from(value: JoinGroupRequest) -> RequestKind

Converts to this type from the input type.

impl From<LeaderAndIsrRequest> for RequestKind

fn from(value: LeaderAndIsrRequest) -> RequestKind

Converts to this type from the input type.

impl From<LeaveGroupRequest> for RequestKind

fn from(value: LeaveGroupRequest) -> RequestKind

Converts to this type from the input type.

impl From<ListClientMetricsResourcesRequest> for RequestKind

fn from(value: ListClientMetricsResourcesRequest) -> RequestKind

Converts to this type from the input type.

impl From<ListGroupsRequest> for RequestKind

fn from(value: ListGroupsRequest) -> RequestKind

Converts to this type from the input type.

impl From<ListOffsetsRequest> for RequestKind

fn from(value: ListOffsetsRequest) -> RequestKind

Converts to this type from the input type.

impl From<ListPartitionReassignmentsRequest> for RequestKind

fn from(value: ListPartitionReassignmentsRequest) -> RequestKind

Converts to this type from the input type.

impl From<ListTransactionsRequest> for RequestKind

fn from(value: ListTransactionsRequest) -> RequestKind

Converts to this type from the input type.

impl From<MetadataRequest> for RequestKind

fn from(value: MetadataRequest) -> RequestKind

Converts to this type from the input type.

impl From<OffsetCommitRequest> for RequestKind

fn from(value: OffsetCommitRequest) -> RequestKind

Converts to this type from the input type.

impl From<OffsetDeleteRequest> for RequestKind

fn from(value: OffsetDeleteRequest) -> RequestKind

Converts to this type from the input type.

impl From<OffsetFetchRequest> for RequestKind

fn from(value: OffsetFetchRequest) -> RequestKind

Converts to this type from the input type.

impl From<OffsetForLeaderEpochRequest> for RequestKind

fn from(value: OffsetForLeaderEpochRequest) -> RequestKind

Converts to this type from the input type.

impl From<ProduceRequest> for RequestKind

fn from(value: ProduceRequest) -> RequestKind

Converts to this type from the input type.

impl From<PushTelemetryRequest> for RequestKind

fn from(value: PushTelemetryRequest) -> RequestKind

Converts to this type from the input type.

impl From<RenewDelegationTokenRequest> for RequestKind

fn from(value: RenewDelegationTokenRequest) -> RequestKind

Converts to this type from the input type.

impl From<SaslAuthenticateRequest> for RequestKind

fn from(value: SaslAuthenticateRequest) -> RequestKind

Converts to this type from the input type.

impl From<SaslHandshakeRequest> for RequestKind

fn from(value: SaslHandshakeRequest) -> RequestKind

Converts to this type from the input type.

impl From<StopReplicaRequest> for RequestKind

fn from(value: StopReplicaRequest) -> RequestKind

Converts to this type from the input type.

impl From<SyncGroupRequest> for RequestKind

fn from(value: SyncGroupRequest) -> RequestKind

Converts to this type from the input type.

impl From<TxnOffsetCommitRequest> for RequestKind

fn from(value: TxnOffsetCommitRequest) -> RequestKind

Converts to this type from the input type.

impl From<UnregisterBrokerRequest> for RequestKind

fn from(value: UnregisterBrokerRequest) -> RequestKind

Converts to this type from the input type.

impl From<UpdateFeaturesRequest> for RequestKind

fn from(value: UpdateFeaturesRequest) -> RequestKind

Converts to this type from the input type.

impl From<UpdateMetadataRequest> for RequestKind

fn from(value: UpdateMetadataRequest) -> RequestKind

Converts to this type from the input type.

impl From<VoteRequest> for RequestKind

fn from(value: VoteRequest) -> RequestKind

Converts to this type from the input type.

impl From<WriteTxnMarkersRequest> for RequestKind

fn from(value: WriteTxnMarkersRequest) -> RequestKind

Converts to this type from the input type.

impl PartialEq for RequestKind

fn eq(&self, other: &RequestKind) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl StructuralPartialEq for RequestKind