Enum kafka_protocol::messages::RequestKind

source · [−]

pub enum RequestKind {
Show 68 variants
    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),
    AlterIsrRequest(AlterIsrRequest),
    UpdateFeaturesRequest(UpdateFeaturesRequest),
    EnvelopeRequest(EnvelopeRequest),
    FetchSnapshotRequest(FetchSnapshotRequest),
    DescribeClusterRequest(DescribeClusterRequest),
    DescribeProducersRequest(DescribeProducersRequest),
    BrokerRegistrationRequest(BrokerRegistrationRequest),
    BrokerHeartbeatRequest(BrokerHeartbeatRequest),
    UnregisterBrokerRequest(UnregisterBrokerRequest),
    DescribeTransactionsRequest(DescribeTransactionsRequest),
    ListTransactionsRequest(ListTransactionsRequest),
    AllocateProducerIdsRequest(AllocateProducerIdsRequest),
}

Expand description

Wrapping enum for all requests in the Kafka protocol.

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,

`AlterIsrRequest(AlterIsrRequest)`

AlterIsrRequest,

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

Trait Implementations

source

impl Debug for RequestKind

source

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

Formats the value using the given formatter. Read more

Auto Trait Implementations

impl RefUnwindSafe for RequestKind

impl Send for RequestKind

impl Sync for RequestKind

impl Unpin for RequestKind

fn into(self) -> U

Calls U::from(self).

That is, this conversion is whatever the implementation of From<T> for U chooses to do.

source

impl<T, U> TryFrom for T where
U: Into<T>,

type Error = Infallible

The type returned in the event of a conversion error.

const: unstable · source

fn try_from(value: U) -> Result<T, <T as TryFrom>::Error>

Performs the conversion.

source

impl<T, U> TryInto for T where
U: TryFrom<T>,

type Error = >::Error

The type returned in the event of a conversion error.

const: unstable · source

fn try_into(self) -> Result<U, >::Error>

Performs the conversion.