Enum kafka_protocol::messages::RequestKind

#[non_exhaustive]
pub enum RequestKind {
    ProduceRequest(ProduceRequest),
    FetchRequest(FetchRequest),
    ListOffsetsRequest(ListOffsetsRequest),
    MetadataRequest(MetadataRequest),
    LeaderAndIsrRequest(LeaderAndIsrRequest),
    StopReplicaRequest(StopReplicaRequest),
    UpdateMetadataRequest(UpdateMetadataRequest),
    ControlledShutdownRequest(ControlledShutdownRequest),
    OffsetCommitRequest(OffsetCommitRequest),
    OffsetFetchRequest(OffsetFetchRequest),
    FindCoordinatorRequest(FindCoordinatorRequest),
    JoinGroupRequest(JoinGroupRequest),
    HeartbeatRequest(HeartbeatRequest),
    LeaveGroupRequest(LeaveGroupRequest),
    SyncGroupRequest(SyncGroupRequest),
    DescribeGroupsRequest(DescribeGroupsRequest),
    ListGroupsRequest(ListGroupsRequest),
    SaslHandshakeRequest(SaslHandshakeRequest),
    ApiVersionsRequest(ApiVersionsRequest),
    CreateTopicsRequest(CreateTopicsRequest),
    DeleteTopicsRequest(DeleteTopicsRequest),
    DeleteRecordsRequest(DeleteRecordsRequest),
    InitProducerIdRequest(InitProducerIdRequest),
    OffsetForLeaderEpochRequest(OffsetForLeaderEpochRequest),
    AddPartitionsToTxnRequest(AddPartitionsToTxnRequest),
    AddOffsetsToTxnRequest(AddOffsetsToTxnRequest),
    EndTxnRequest(EndTxnRequest),
    WriteTxnMarkersRequest(WriteTxnMarkersRequest),
    TxnOffsetCommitRequest(TxnOffsetCommitRequest),
    DescribeAclsRequest(DescribeAclsRequest),
    CreateAclsRequest(CreateAclsRequest),
    DeleteAclsRequest(DeleteAclsRequest),
    DescribeConfigsRequest(DescribeConfigsRequest),
    AlterConfigsRequest(AlterConfigsRequest),
    AlterReplicaLogDirsRequest(AlterReplicaLogDirsRequest),
    DescribeLogDirsRequest(DescribeLogDirsRequest),
    SaslAuthenticateRequest(SaslAuthenticateRequest),
    CreatePartitionsRequest(CreatePartitionsRequest),
    CreateDelegationTokenRequest(CreateDelegationTokenRequest),
    RenewDelegationTokenRequest(RenewDelegationTokenRequest),
    ExpireDelegationTokenRequest(ExpireDelegationTokenRequest),
    DescribeDelegationTokenRequest(DescribeDelegationTokenRequest),
    DeleteGroupsRequest(DeleteGroupsRequest),
    ElectLeadersRequest(ElectLeadersRequest),
    IncrementalAlterConfigsRequest(IncrementalAlterConfigsRequest),
    AlterPartitionReassignmentsRequest(AlterPartitionReassignmentsRequest),
    ListPartitionReassignmentsRequest(ListPartitionReassignmentsRequest),
    OffsetDeleteRequest(OffsetDeleteRequest),
    DescribeClientQuotasRequest(DescribeClientQuotasRequest),
    AlterClientQuotasRequest(AlterClientQuotasRequest),
    DescribeUserScramCredentialsRequest(DescribeUserScramCredentialsRequest),
    AlterUserScramCredentialsRequest(AlterUserScramCredentialsRequest),
    VoteRequest(VoteRequest),
    BeginQuorumEpochRequest(BeginQuorumEpochRequest),
    EndQuorumEpochRequest(EndQuorumEpochRequest),
    DescribeQuorumRequest(DescribeQuorumRequest),
    AlterPartitionRequest(AlterPartitionRequest),
    UpdateFeaturesRequest(UpdateFeaturesRequest),
    EnvelopeRequest(EnvelopeRequest),
    FetchSnapshotRequest(FetchSnapshotRequest),
    DescribeClusterRequest(DescribeClusterRequest),
    DescribeProducersRequest(DescribeProducersRequest),
    BrokerRegistrationRequest(BrokerRegistrationRequest),
    BrokerHeartbeatRequest(BrokerHeartbeatRequest),
    UnregisterBrokerRequest(UnregisterBrokerRequest),
    DescribeTransactionsRequest(DescribeTransactionsRequest),
    ListTransactionsRequest(ListTransactionsRequest),
    AllocateProducerIdsRequest(AllocateProducerIdsRequest),
    ConsumerGroupHeartbeatRequest(ConsumerGroupHeartbeatRequest),
    ControllerRegistrationRequest(ControllerRegistrationRequest),
    GetTelemetrySubscriptionsRequest(GetTelemetrySubscriptionsRequest),
    PushTelemetryRequest(PushTelemetryRequest),
    AssignReplicasToDirsRequest(AssignReplicasToDirsRequest),
    ListClientMetricsResourcesRequest(ListClientMetricsResourcesRequest),
}

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.

ProduceRequest(ProduceRequest)

ProduceRequest,

FetchRequest(FetchRequest)

FetchRequest,

ListOffsetsRequest(ListOffsetsRequest)

ListOffsetsRequest,

MetadataRequest(MetadataRequest)

MetadataRequest,

LeaderAndIsrRequest(LeaderAndIsrRequest)

LeaderAndIsrRequest,

StopReplicaRequest(StopReplicaRequest)

StopReplicaRequest,

UpdateMetadataRequest(UpdateMetadataRequest)

UpdateMetadataRequest,

ControlledShutdownRequest(ControlledShutdownRequest)

ControlledShutdownRequest,

OffsetCommitRequest(OffsetCommitRequest)

OffsetCommitRequest,

OffsetFetchRequest(OffsetFetchRequest)

OffsetFetchRequest,

FindCoordinatorRequest(FindCoordinatorRequest)

FindCoordinatorRequest,

JoinGroupRequest(JoinGroupRequest)

JoinGroupRequest,

HeartbeatRequest(HeartbeatRequest)

HeartbeatRequest,

LeaveGroupRequest(LeaveGroupRequest)

LeaveGroupRequest,

SyncGroupRequest(SyncGroupRequest)

SyncGroupRequest,

DescribeGroupsRequest(DescribeGroupsRequest)

DescribeGroupsRequest,

ListGroupsRequest(ListGroupsRequest)

ListGroupsRequest,

SaslHandshakeRequest(SaslHandshakeRequest)

SaslHandshakeRequest,

ApiVersionsRequest(ApiVersionsRequest)

ApiVersionsRequest,

CreateTopicsRequest(CreateTopicsRequest)

CreateTopicsRequest,

DeleteTopicsRequest(DeleteTopicsRequest)

DeleteTopicsRequest,

DeleteRecordsRequest(DeleteRecordsRequest)

DeleteRecordsRequest,

InitProducerIdRequest(InitProducerIdRequest)

InitProducerIdRequest,

OffsetForLeaderEpochRequest(OffsetForLeaderEpochRequest)

OffsetForLeaderEpochRequest,

AddPartitionsToTxnRequest(AddPartitionsToTxnRequest)

AddPartitionsToTxnRequest,

AddOffsetsToTxnRequest(AddOffsetsToTxnRequest)

AddOffsetsToTxnRequest,

EndTxnRequest(EndTxnRequest)

EndTxnRequest,

WriteTxnMarkersRequest(WriteTxnMarkersRequest)

WriteTxnMarkersRequest,

TxnOffsetCommitRequest(TxnOffsetCommitRequest)

TxnOffsetCommitRequest,

DescribeAclsRequest(DescribeAclsRequest)

DescribeAclsRequest,

CreateAclsRequest(CreateAclsRequest)

CreateAclsRequest,

DeleteAclsRequest(DeleteAclsRequest)

DeleteAclsRequest,

DescribeConfigsRequest(DescribeConfigsRequest)

DescribeConfigsRequest,

AlterConfigsRequest(AlterConfigsRequest)

AlterConfigsRequest,

AlterReplicaLogDirsRequest(AlterReplicaLogDirsRequest)

AlterReplicaLogDirsRequest,

DescribeLogDirsRequest(DescribeLogDirsRequest)

DescribeLogDirsRequest,

SaslAuthenticateRequest(SaslAuthenticateRequest)

SaslAuthenticateRequest,

CreatePartitionsRequest(CreatePartitionsRequest)

CreatePartitionsRequest,

CreateDelegationTokenRequest(CreateDelegationTokenRequest)

CreateDelegationTokenRequest,

RenewDelegationTokenRequest(RenewDelegationTokenRequest)

RenewDelegationTokenRequest,

ExpireDelegationTokenRequest(ExpireDelegationTokenRequest)

ExpireDelegationTokenRequest,

DescribeDelegationTokenRequest(DescribeDelegationTokenRequest)

DescribeDelegationTokenRequest,

DeleteGroupsRequest(DeleteGroupsRequest)

DeleteGroupsRequest,

ElectLeadersRequest(ElectLeadersRequest)

ElectLeadersRequest,

IncrementalAlterConfigsRequest(IncrementalAlterConfigsRequest)

IncrementalAlterConfigsRequest,

AlterPartitionReassignmentsRequest(AlterPartitionReassignmentsRequest)

AlterPartitionReassignmentsRequest,

ListPartitionReassignmentsRequest(ListPartitionReassignmentsRequest)

ListPartitionReassignmentsRequest,

OffsetDeleteRequest(OffsetDeleteRequest)

OffsetDeleteRequest,

DescribeClientQuotasRequest(DescribeClientQuotasRequest)

DescribeClientQuotasRequest,

AlterClientQuotasRequest(AlterClientQuotasRequest)

AlterClientQuotasRequest,

DescribeUserScramCredentialsRequest(DescribeUserScramCredentialsRequest)

DescribeUserScramCredentialsRequest,

AlterUserScramCredentialsRequest(AlterUserScramCredentialsRequest)

AlterUserScramCredentialsRequest,

VoteRequest(VoteRequest)

VoteRequest,

BeginQuorumEpochRequest(BeginQuorumEpochRequest)

BeginQuorumEpochRequest,

EndQuorumEpochRequest(EndQuorumEpochRequest)

EndQuorumEpochRequest,

DescribeQuorumRequest(DescribeQuorumRequest)

DescribeQuorumRequest,

AlterPartitionRequest(AlterPartitionRequest)

AlterPartitionRequest,

UpdateFeaturesRequest(UpdateFeaturesRequest)

UpdateFeaturesRequest,

EnvelopeRequest(EnvelopeRequest)

EnvelopeRequest,

FetchSnapshotRequest(FetchSnapshotRequest)

FetchSnapshotRequest,

DescribeClusterRequest(DescribeClusterRequest)

DescribeClusterRequest,

DescribeProducersRequest(DescribeProducersRequest)

DescribeProducersRequest,

BrokerRegistrationRequest(BrokerRegistrationRequest)

BrokerRegistrationRequest,

BrokerHeartbeatRequest(BrokerHeartbeatRequest)

BrokerHeartbeatRequest,

UnregisterBrokerRequest(UnregisterBrokerRequest)

UnregisterBrokerRequest,

DescribeTransactionsRequest(DescribeTransactionsRequest)

DescribeTransactionsRequest,

ListTransactionsRequest(ListTransactionsRequest)

ListTransactionsRequest,

AllocateProducerIdsRequest(AllocateProducerIdsRequest)

AllocateProducerIdsRequest,

ConsumerGroupHeartbeatRequest(ConsumerGroupHeartbeatRequest)

ConsumerGroupHeartbeatRequest,

ControllerRegistrationRequest(ControllerRegistrationRequest)

ControllerRegistrationRequest,

GetTelemetrySubscriptionsRequest(GetTelemetrySubscriptionsRequest)

GetTelemetrySubscriptionsRequest,

PushTelemetryRequest(PushTelemetryRequest)

PushTelemetryRequest,

AssignReplicasToDirsRequest(AssignReplicasToDirsRequest)

AssignReplicasToDirsRequest,

ListClientMetricsResourcesRequest(ListClientMetricsResourcesRequest)

ListClientMetricsResourcesRequest,

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<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<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

This method tests for self and other values to be equal, and is used by ==.

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

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

impl StructuralPartialEq for RequestKind