kafka_protocol::messages

Enum ApiKey

Source 
pub enum ApiKey {

Show 79 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,
    ApiVersions = 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,
    AlterPartition = 56,
    UpdateFeatures = 57,
    Envelope = 58,
    FetchSnapshot = 59,
    DescribeCluster = 60,
    DescribeProducers = 61,
    BrokerRegistration = 62,
    BrokerHeartbeat = 63,
    UnregisterBroker = 64,
    DescribeTransactions = 65,
    ListTransactions = 66,
    AllocateProducerIds = 67,
    ConsumerGroupHeartbeat = 68,
    ConsumerGroupDescribe = 69,
    ControllerRegistration = 70,
    GetTelemetrySubscriptions = 71,
    PushTelemetry = 72,
    AssignReplicasToDirs = 73,
    ListClientMetricsResources = 74,
    DescribeTopicPartitions = 75,
    AddRaftVoter = 80,
    RemoveRaftVoter = 81,
    UpdateRaftVoter = 82,

}
Expand description

Valid API keys in the Kafka protocol.

Variants§

§

Produce = 0

API key for request ProduceRequest

§

Fetch = 1

API key for request FetchRequest

§

ListOffsets = 2

API key for request ListOffsetsRequest

§

Metadata = 3

API key for request MetadataRequest

§

LeaderAndIsr = 4

API key for request LeaderAndIsrRequest

§

StopReplica = 5

API key for request StopReplicaRequest

§

UpdateMetadata = 6

API key for request UpdateMetadataRequest

§

ControlledShutdown = 7

API key for request ControlledShutdownRequest

§

OffsetCommit = 8

API key for request OffsetCommitRequest

§

OffsetFetch = 9

API key for request OffsetFetchRequest

§

FindCoordinator = 10

API key for request FindCoordinatorRequest

§

JoinGroup = 11

API key for request JoinGroupRequest

§

Heartbeat = 12

API key for request HeartbeatRequest

§

LeaveGroup = 13

API key for request LeaveGroupRequest

§

SyncGroup = 14

API key for request SyncGroupRequest

§

DescribeGroups = 15

API key for request DescribeGroupsRequest

§

ListGroups = 16

API key for request ListGroupsRequest

§

SaslHandshake = 17

API key for request SaslHandshakeRequest

§

ApiVersions = 18

API key for request ApiVersionsRequest

§

CreateTopics = 19

API key for request CreateTopicsRequest

§

DeleteTopics = 20

API key for request DeleteTopicsRequest

§

DeleteRecords = 21

API key for request DeleteRecordsRequest

§

InitProducerId = 22

API key for request InitProducerIdRequest

§

OffsetForLeaderEpoch = 23

API key for request OffsetForLeaderEpochRequest

§

AddPartitionsToTxn = 24

API key for request AddPartitionsToTxnRequest

§

AddOffsetsToTxn = 25

API key for request AddOffsetsToTxnRequest

§

EndTxn = 26

API key for request EndTxnRequest

§

WriteTxnMarkers = 27

API key for request WriteTxnMarkersRequest

§

TxnOffsetCommit = 28

API key for request TxnOffsetCommitRequest

§

DescribeAcls = 29

API key for request DescribeAclsRequest

§

CreateAcls = 30

API key for request CreateAclsRequest

§

DeleteAcls = 31

API key for request DeleteAclsRequest

§

DescribeConfigs = 32

API key for request DescribeConfigsRequest

§

AlterConfigs = 33

API key for request AlterConfigsRequest

§

AlterReplicaLogDirs = 34

API key for request AlterReplicaLogDirsRequest

§

DescribeLogDirs = 35

API key for request DescribeLogDirsRequest

§

SaslAuthenticate = 36

API key for request SaslAuthenticateRequest

§

CreatePartitions = 37

API key for request CreatePartitionsRequest

§

CreateDelegationToken = 38

API key for request CreateDelegationTokenRequest

§

RenewDelegationToken = 39

API key for request RenewDelegationTokenRequest

§

ExpireDelegationToken = 40

API key for request ExpireDelegationTokenRequest

§

DescribeDelegationToken = 41

API key for request DescribeDelegationTokenRequest

§

DeleteGroups = 42

API key for request DeleteGroupsRequest

§

ElectLeaders = 43

API key for request ElectLeadersRequest

§

IncrementalAlterConfigs = 44

API key for request IncrementalAlterConfigsRequest

§

AlterPartitionReassignments = 45

API key for request AlterPartitionReassignmentsRequest

§

ListPartitionReassignments = 46

API key for request ListPartitionReassignmentsRequest

§

OffsetDelete = 47

API key for request OffsetDeleteRequest

§

DescribeClientQuotas = 48

API key for request DescribeClientQuotasRequest

§

AlterClientQuotas = 49

API key for request AlterClientQuotasRequest

§

DescribeUserScramCredentials = 50

API key for request DescribeUserScramCredentialsRequest

§

AlterUserScramCredentials = 51

API key for request AlterUserScramCredentialsRequest

§

Vote = 52

API key for request VoteRequest

§

BeginQuorumEpoch = 53

API key for request BeginQuorumEpochRequest

§

EndQuorumEpoch = 54

API key for request EndQuorumEpochRequest

§

DescribeQuorum = 55

API key for request DescribeQuorumRequest

§

AlterPartition = 56

API key for request AlterPartitionRequest

§

UpdateFeatures = 57

API key for request UpdateFeaturesRequest

§

Envelope = 58

API key for request EnvelopeRequest

§

FetchSnapshot = 59

API key for request FetchSnapshotRequest

§

DescribeCluster = 60

API key for request DescribeClusterRequest

§

DescribeProducers = 61

API key for request DescribeProducersRequest

§

BrokerRegistration = 62

API key for request BrokerRegistrationRequest

§

BrokerHeartbeat = 63

API key for request BrokerHeartbeatRequest

§

UnregisterBroker = 64

API key for request UnregisterBrokerRequest

§

DescribeTransactions = 65

API key for request DescribeTransactionsRequest

§

ListTransactions = 66

API key for request ListTransactionsRequest

§

AllocateProducerIds = 67

API key for request AllocateProducerIdsRequest

§

ConsumerGroupHeartbeat = 68

API key for request ConsumerGroupHeartbeatRequest

§

ConsumerGroupDescribe = 69

API key for request ConsumerGroupDescribeRequest

§

ControllerRegistration = 70

API key for request ControllerRegistrationRequest

§

GetTelemetrySubscriptions = 71

API key for request GetTelemetrySubscriptionsRequest

§

PushTelemetry = 72

API key for request PushTelemetryRequest

§

AssignReplicasToDirs = 73

API key for request AssignReplicasToDirsRequest

§

ListClientMetricsResources = 74

API key for request ListClientMetricsResourcesRequest

§

DescribeTopicPartitions = 75

API key for request DescribeTopicPartitionsRequest

§

AddRaftVoter = 80

API key for request AddRaftVoterRequest

§

RemoveRaftVoter = 81

API key for request RemoveRaftVoterRequest

§

UpdateRaftVoter = 82

API key for request UpdateRaftVoterRequest

Implementations§

Source§

impl ApiKey

Source

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

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

Source

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

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

Source

pub fn valid_versions(&self) -> VersionRange

Returns the valid versions that can be used with this ApiKey

Source

pub fn iter() -> impl Iterator<Item = ApiKey>

Iterate through every ApiKey variant in the order of the internal code.

Trait Implementations§

Source§

impl Clone for ApiKey

Source§

fn clone(&self) -> ApiKey

Returns a copy of the value. Read more
1.0.0 · Source§

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

Performs copy-assignment from source. Read more
Source§

impl Debug for ApiKey

Source§

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

Formats the value using the given formatter. Read more
Source§

impl PartialEq for ApiKey

Source§

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

Tests for self and other values to be equal, and is used by ==.
1.0.0 · Source§

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

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

impl TryFrom<i16> for ApiKey

Source§

type Error = ()

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

impl Copy for ApiKey

Source§

impl Eq for ApiKey

Source§

impl StructuralPartialEq for ApiKey

Auto Trait Implementations§

§

impl Freeze for ApiKey

§

impl RefUnwindSafe for ApiKey

§

impl Send for ApiKey

§

impl Sync for ApiKey

§

impl Unpin for ApiKey

§

impl UnwindSafe for ApiKey

Blanket Implementations§

Source§

impl<T> Any for T
where T: 'static + ?Sized,

Source§

fn type_id(&self) -> TypeId

Gets the TypeId of self. Read more
Source§

impl<T> Borrow<T> for T
where T: ?Sized,

Source§

fn borrow(&self) -> &T

Immutably borrows from an owned value. Read more
Source§

impl<T> BorrowMut<T> for T
where T: ?Sized,

Source§

fn borrow_mut(&mut self) -> &mut T

Mutably borrows from an owned value. Read more
Source§

impl<T> CloneToUninit for T
where T: Clone,

Source§

unsafe fn clone_to_uninit(&self, dest: *mut u8)

🔬This is a nightly-only experimental API. (clone_to_uninit)
Performs copy-assignment from self to dest. Read more
Source§

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

Source§

fn equivalent(&self, key: &K) -> bool

Checks if this value is equivalent to the given key. Read more
Source§

impl<Q, K> Equivalent<K> for Q
where Q: Eq + ?Sized, K: Borrow<Q> + ?Sized,

Source§

fn equivalent(&self, key: &K) -> bool

Compare self to key and return true if they are equal.
Source§

impl<T> From<T> for T

Source§

fn from(t: T) -> T

Returns the argument unchanged.

Source§

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

Source§

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> ToOwned for T
where T: Clone,

Source§

type Owned = T

The resulting type after obtaining ownership.
Source§

fn to_owned(&self) -> T

Creates owned data from borrowed data, usually by cloning. Read more
Source§

fn clone_into(&self, target: &mut T)

Uses borrowed data to replace owned data, usually by cloning. Read more
Source§

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

Source§

type Error = Infallible

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.
Source§

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

Source§

type Error = <U as TryFrom<T>>::Error

The type returned in the event of a conversion error.
Source§

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

Performs the conversion.