Enum RDKafkaApiKey

#[non_exhaustive]
#[repr(i16)]
pub enum RDKafkaApiKey {
    Produce = 0,
    Fetch = 1,
    ListOffsets = 2,
    Metadata = 3,
    LeaderAndIsr = 4,
    StopReplica = 5,
    UpdateMetadata = 6,
    ControlledShutdown = 7,
    OffsetCommit = 8,
    OffsetFetch = 9,
    FindCoordinator = 10,
    JoinGroup = 11,
    Heartbeat = 12,
    LeaveGroup = 13,
    SyncGroup = 14,
    DescribeGroups = 15,
    ListGroups = 16,
    SaslHandshake = 17,
    ApiVersion = 18,
    CreateTopics = 19,
    DeleteTopics = 20,
    DeleteRecords = 21,
    InitProducerId = 22,
    OffsetForLeaderEpoch = 23,
    AddPartitionsToTxn = 24,
    AddOffsetsToTxn = 25,
    EndTxn = 26,
    WriteTxnMarkers = 27,
    TxnOffsetCommit = 28,
    DescribeAcls = 29,
    CreateAcls = 30,
    DeleteAcls = 31,
    DescribeConfigs = 32,
    AlterConfigs = 33,
    AlterReplicaLogDirs = 34,
    DescribeLogDirs = 35,
    SaslAuthenticate = 36,
    CreatePartitions = 37,
    CreateDelegationToken = 38,
    RenewDelegationToken = 39,
    ExpireDelegationToken = 40,
    DescribeDelegationToken = 41,
    DeleteGroups = 42,
    ElectLeaders = 43,
    IncrementalAlterConfigs = 44,
    AlterPartitionReassignments = 45,
    ListPartitionReassignments = 46,
    OffsetDelete = 47,
    DescribeClientQuotas = 48,
    AlterClientQuotas = 49,
    DescribeUserScramCredentials = 50,
    AlterUserScramCredentials = 51,
    Vote = 52,
    BeginQuorumEpoch = 53,
    EndQuorumEpoch = 54,
    DescribeQuorum = 55,
    AlterIsr = 56,
    UpdateFeatures = 57,
    Envelope = 58,
}

Native rdkafka ApiKeys / protocol requests

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

Fetch = 1

ListOffsets = 2

Metadata = 3

LeaderAndIsr = 4

StopReplica = 5

UpdateMetadata = 6

ControlledShutdown = 7

OffsetCommit = 8

OffsetFetch = 9

FindCoordinator = 10

JoinGroup = 11

Heartbeat = 12

LeaveGroup = 13

SyncGroup = 14

DescribeGroups = 15

ListGroups = 16

SaslHandshake = 17

ApiVersion = 18

CreateTopics = 19

DeleteTopics = 20

DeleteRecords = 21

InitProducerId = 22

OffsetForLeaderEpoch = 23

AddPartitionsToTxn = 24

AddOffsetsToTxn = 25

EndTxn = 26

WriteTxnMarkers = 27

TxnOffsetCommit = 28

DescribeAcls = 29

CreateAcls = 30

DeleteAcls = 31

DescribeConfigs = 32

AlterConfigs = 33

AlterReplicaLogDirs = 34

DescribeLogDirs = 35

SaslAuthenticate = 36

CreatePartitions = 37

CreateDelegationToken = 38

RenewDelegationToken = 39

ExpireDelegationToken = 40

DescribeDelegationToken = 41

DeleteGroups = 42

ElectLeaders = 43

IncrementalAlterConfigs = 44

AlterPartitionReassignments = 45

ListPartitionReassignments = 46

OffsetDelete = 47

DescribeClientQuotas = 48

AlterClientQuotas = 49

DescribeUserScramCredentials = 50

AlterUserScramCredentials = 51

Vote = 52

BeginQuorumEpoch = 53

EndQuorumEpoch = 54

DescribeQuorum = 55

AlterIsr = 56

UpdateFeatures = 57

Envelope = 58

Trait Implementations

impl Clone for RDKafkaApiKey

fn clone(&self) -> RDKafkaApiKey

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RDKafkaApiKey

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

Formats the value using the given formatter.

impl From<RDKafkaApiKey> for i16

fn from(enum_value: RDKafkaApiKey) -> Self

Converts to this type from the input type.

impl PartialEq for RDKafkaApiKey

fn eq(&self, other: &RDKafkaApiKey) -> 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 Copy for RDKafkaApiKey

impl Eq for RDKafkaApiKey

impl StructuralPartialEq for RDKafkaApiKey