Enum kafka_protocol::messages::ApiKey

pub enum ApiKey {
    ProduceKey = 0,
    FetchKey = 1,
    ListOffsetsKey = 2,
    MetadataKey = 3,
    LeaderAndIsrKey = 4,
    StopReplicaKey = 5,
    UpdateMetadataKey = 6,
    ControlledShutdownKey = 7,
    OffsetCommitKey = 8,
    OffsetFetchKey = 9,
    FindCoordinatorKey = 10,
    JoinGroupKey = 11,
    HeartbeatKey = 12,
    LeaveGroupKey = 13,
    SyncGroupKey = 14,
    DescribeGroupsKey = 15,
    ListGroupsKey = 16,
    SaslHandshakeKey = 17,
    ApiVersionsKey = 18,
    CreateTopicsKey = 19,
    DeleteTopicsKey = 20,
    DeleteRecordsKey = 21,
    InitProducerIdKey = 22,
    OffsetForLeaderEpochKey = 23,
    AddPartitionsToTxnKey = 24,
    AddOffsetsToTxnKey = 25,
    EndTxnKey = 26,
    WriteTxnMarkersKey = 27,
    TxnOffsetCommitKey = 28,
    DescribeAclsKey = 29,
    CreateAclsKey = 30,
    DeleteAclsKey = 31,
    DescribeConfigsKey = 32,
    AlterConfigsKey = 33,
    AlterReplicaLogDirsKey = 34,
    DescribeLogDirsKey = 35,
    SaslAuthenticateKey = 36,
    CreatePartitionsKey = 37,
    CreateDelegationTokenKey = 38,
    RenewDelegationTokenKey = 39,
    ExpireDelegationTokenKey = 40,
    DescribeDelegationTokenKey = 41,
    DeleteGroupsKey = 42,
    ElectLeadersKey = 43,
    IncrementalAlterConfigsKey = 44,
    AlterPartitionReassignmentsKey = 45,
    ListPartitionReassignmentsKey = 46,
    OffsetDeleteKey = 47,
    DescribeClientQuotasKey = 48,
    AlterClientQuotasKey = 49,
    DescribeUserScramCredentialsKey = 50,
    AlterUserScramCredentialsKey = 51,
    VoteKey = 52,
    BeginQuorumEpochKey = 53,
    EndQuorumEpochKey = 54,
    DescribeQuorumKey = 55,
    AlterPartitionKey = 56,
    UpdateFeaturesKey = 57,
    EnvelopeKey = 58,
    FetchSnapshotKey = 59,
    DescribeClusterKey = 60,
    DescribeProducersKey = 61,
    BrokerRegistrationKey = 62,
    BrokerHeartbeatKey = 63,
    UnregisterBrokerKey = 64,
    DescribeTransactionsKey = 65,
    ListTransactionsKey = 66,
    AllocateProducerIdsKey = 67,
    ConsumerGroupHeartbeatKey = 68,
    ControllerRegistrationKey = 70,
    GetTelemetrySubscriptionsKey = 71,
    PushTelemetryKey = 72,
    AssignReplicasToDirsKey = 73,
    ListClientMetricsResourcesKey = 74,
}

Valid API keys in the Kafka protocol.

Variants

ProduceKey = 0

API key for request ProduceRequest

FetchKey = 1

API key for request FetchRequest

ListOffsetsKey = 2

API key for request ListOffsetsRequest

MetadataKey = 3

API key for request MetadataRequest

LeaderAndIsrKey = 4

API key for request LeaderAndIsrRequest

StopReplicaKey = 5

API key for request StopReplicaRequest

UpdateMetadataKey = 6

API key for request UpdateMetadataRequest

ControlledShutdownKey = 7

API key for request ControlledShutdownRequest

OffsetCommitKey = 8

API key for request OffsetCommitRequest

OffsetFetchKey = 9

API key for request OffsetFetchRequest

FindCoordinatorKey = 10

API key for request FindCoordinatorRequest

JoinGroupKey = 11

API key for request JoinGroupRequest

HeartbeatKey = 12

API key for request HeartbeatRequest

LeaveGroupKey = 13

API key for request LeaveGroupRequest

SyncGroupKey = 14

API key for request SyncGroupRequest

DescribeGroupsKey = 15

API key for request DescribeGroupsRequest

ListGroupsKey = 16

API key for request ListGroupsRequest

SaslHandshakeKey = 17

API key for request SaslHandshakeRequest

ApiVersionsKey = 18

API key for request ApiVersionsRequest

CreateTopicsKey = 19

API key for request CreateTopicsRequest

DeleteTopicsKey = 20

API key for request DeleteTopicsRequest

DeleteRecordsKey = 21

API key for request DeleteRecordsRequest

InitProducerIdKey = 22

API key for request InitProducerIdRequest

OffsetForLeaderEpochKey = 23

API key for request OffsetForLeaderEpochRequest

AddPartitionsToTxnKey = 24

API key for request AddPartitionsToTxnRequest

AddOffsetsToTxnKey = 25

API key for request AddOffsetsToTxnRequest

EndTxnKey = 26

API key for request EndTxnRequest

WriteTxnMarkersKey = 27

API key for request WriteTxnMarkersRequest

TxnOffsetCommitKey = 28

API key for request TxnOffsetCommitRequest

DescribeAclsKey = 29

API key for request DescribeAclsRequest

CreateAclsKey = 30

API key for request CreateAclsRequest

DeleteAclsKey = 31

API key for request DeleteAclsRequest

DescribeConfigsKey = 32

API key for request DescribeConfigsRequest

AlterConfigsKey = 33

API key for request AlterConfigsRequest

AlterReplicaLogDirsKey = 34

API key for request AlterReplicaLogDirsRequest

DescribeLogDirsKey = 35

API key for request DescribeLogDirsRequest

SaslAuthenticateKey = 36

API key for request SaslAuthenticateRequest

CreatePartitionsKey = 37

API key for request CreatePartitionsRequest

CreateDelegationTokenKey = 38

API key for request CreateDelegationTokenRequest

RenewDelegationTokenKey = 39

API key for request RenewDelegationTokenRequest

ExpireDelegationTokenKey = 40

API key for request ExpireDelegationTokenRequest

DescribeDelegationTokenKey = 41

API key for request DescribeDelegationTokenRequest

DeleteGroupsKey = 42

API key for request DeleteGroupsRequest

ElectLeadersKey = 43

API key for request ElectLeadersRequest

IncrementalAlterConfigsKey = 44

API key for request IncrementalAlterConfigsRequest

AlterPartitionReassignmentsKey = 45

API key for request AlterPartitionReassignmentsRequest

ListPartitionReassignmentsKey = 46

API key for request ListPartitionReassignmentsRequest

OffsetDeleteKey = 47

API key for request OffsetDeleteRequest

DescribeClientQuotasKey = 48

API key for request DescribeClientQuotasRequest

AlterClientQuotasKey = 49

API key for request AlterClientQuotasRequest

DescribeUserScramCredentialsKey = 50

API key for request DescribeUserScramCredentialsRequest

AlterUserScramCredentialsKey = 51

API key for request AlterUserScramCredentialsRequest

VoteKey = 52

API key for request VoteRequest

BeginQuorumEpochKey = 53

API key for request BeginQuorumEpochRequest

EndQuorumEpochKey = 54

API key for request EndQuorumEpochRequest

DescribeQuorumKey = 55

API key for request DescribeQuorumRequest

AlterPartitionKey = 56

API key for request AlterPartitionRequest

UpdateFeaturesKey = 57

API key for request UpdateFeaturesRequest

EnvelopeKey = 58

API key for request EnvelopeRequest

FetchSnapshotKey = 59

API key for request FetchSnapshotRequest

DescribeClusterKey = 60

API key for request DescribeClusterRequest

DescribeProducersKey = 61

API key for request DescribeProducersRequest

BrokerRegistrationKey = 62

API key for request BrokerRegistrationRequest

BrokerHeartbeatKey = 63

API key for request BrokerHeartbeatRequest

UnregisterBrokerKey = 64

API key for request UnregisterBrokerRequest

DescribeTransactionsKey = 65

API key for request DescribeTransactionsRequest

ListTransactionsKey = 66

API key for request ListTransactionsRequest

AllocateProducerIdsKey = 67

API key for request AllocateProducerIdsRequest

ConsumerGroupHeartbeatKey = 68

API key for request ConsumerGroupHeartbeatRequest

ControllerRegistrationKey = 70

API key for request ControllerRegistrationRequest

GetTelemetrySubscriptionsKey = 71

API key for request GetTelemetrySubscriptionsRequest

PushTelemetryKey = 72

API key for request PushTelemetryRequest

AssignReplicasToDirsKey = 73

API key for request AssignReplicasToDirsRequest

ListClientMetricsResourcesKey = 74

API key for request ListClientMetricsResourcesRequest

Implementations

impl ApiKey

pub fn request_header_version(&self, version: i16) -> i16

Get the version of request header that needs to be prepended to this message

pub fn response_header_version(&self, version: i16) -> i16

Get the version of response header that needs to be prepended to this message

Trait Implementations

impl Clone for ApiKey

fn clone(&self) -> ApiKey

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ApiKey

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

Formats the value using the given formatter.

impl PartialEq for ApiKey

fn eq(&self, other: &ApiKey) -> 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 TryFrom<i16> for ApiKey

type Error = ()

The type returned in the event of a conversion error.

fn try_from(v: i16) -> Result<Self, Self::Error>

Performs the conversion.

impl Copy for ApiKey

impl Eq for ApiKey

impl StructuralPartialEq for ApiKey