Enum ErrorCode

#[repr(i16)]
pub enum ErrorCode {
    UnknownServerError = -1,
    None = 0,
    OffsetOutOfRange = 1,
    CorruptMessage = 2,
    UnknownTopicOrPartition = 3,
    InvalidFetchSize = 4,
    LeaderNotAvailable = 5,
    NotLeaderForPartition = 6,
    RequestTimedOut = 7,
    BrokerNotAvailable = 8,
    ReplicaNotAvailable = 9,
    MessageTooLarge = 10,
    StaleControllerEpoch = 11,
    OffsetMetadataTooLarge = 12,
    NetworkException = 13,
    CoordinatorLoadInProgress = 14,
    CoordinatorNotAvailable = 15,
    NotCoordinator = 16,
    InvalidTopicException = 17,
    RecordListTooLarge = 18,
    NotEnoughReplicas = 19,
    NotEnougReplicasAfterAppend = 20,
    InvalidRequiredAcks = 21,
    IllegalGeneration = 22,
    InconsistentGroupProtocol = 23,
    InvalidGroupId = 24,
    UnknownMemberId = 25,
    InvalidSessionTimeout = 26,
    RebalanceInProgress = 27,
    InvalidCommitOffsetSize = 28,
    TopicAuthorizationFailed = 29,
    GroupAuthorizationFailed = 30,
    ClusterAuthorizationFailed = 31,
    InvalidTimestamp = 32,
    UnsupportedSaslMechanism = 33,
    IllegalSaslState = 34,
    UnsupportedVersion = 35,
    TopicAlreadyExists = 36,
    InvalidPartitions = 37,
    InvalidReplicationFactor = 38,
    InvalidReplicaAssignment = 39,
    InvalidConfig = 40,
    NotController = 41,
    InvalidRequest = 42,
    UnsupportedForMessageFormat = 43,
    PolicyViolation = 44,
    OutOfOrderSequenceNumber = 45,
    DuplicateSequenceNumber = 46,
    InvalidProducerEpoch = 47,
    InvalidTxnState = 48,
    InvalidProducerIdMapping = 49,
    InvalidTransactionTimeout = 50,
    ConcurrentTransactions = 51,
    TransactionCoordinatorFenced = 52,
    TransactionalIdAuthorizationFailed = 53,
    SecurityDisabled = 54,
    OperationNotAttempted = 55,
    KafkaStorageError = 56,
    LogDirNotFound = 57,
    SaslAuthenticationFailed = 58,
    UnknownProducerId = 59,
    ReassignmentInProgress = 60,
    DelegationTokenAuthDisabled = 61,
    DelegationTokenNotFound = 62,
    DelegationTokenOwnerMismatch = 63,
    DelegationTokenRequestNotAllowed = 64,
    DelegationTokenAuthorizationFailed = 65,
    DelegationTokenExpired = 66,
    InvalidPrincipleType = 67,
    NonEmptyGroup = 68,
    GroupIdNotFound = 69,
    FetchSessionIdNotFound = 70,
    InvalidFetchSessionEpoch = 71,
    ListenerNotFound = 72,
    TopicDeletionDisabled = 73,
    FencedLeaderEpoch = 74,
    UnknownLeaderEpoch = 75,
    UnsupportedCompressionType = 76,
    StaleBrokerEpoch = 77,
    OffsetNotAvailable = 78,
    MemberIdRequired = 79,
    PreferredLeaderNotAvailable = 80,
    GroupMaxSizeReached = 81,
}

kafka error https://kafka.apache.org/protocol#protocol_types

Variants

UnknownServerError = -1

None = 0

OffsetOutOfRange = 1

CorruptMessage = 2

UnknownTopicOrPartition = 3

InvalidFetchSize = 4

LeaderNotAvailable = 5

NotLeaderForPartition = 6

RequestTimedOut = 7

BrokerNotAvailable = 8

ReplicaNotAvailable = 9

MessageTooLarge = 10

StaleControllerEpoch = 11

OffsetMetadataTooLarge = 12

NetworkException = 13

CoordinatorLoadInProgress = 14

CoordinatorNotAvailable = 15

NotCoordinator = 16

InvalidTopicException = 17

RecordListTooLarge = 18

NotEnoughReplicas = 19

NotEnougReplicasAfterAppend = 20

InvalidRequiredAcks = 21

IllegalGeneration = 22

InconsistentGroupProtocol = 23

InvalidGroupId = 24

UnknownMemberId = 25

InvalidSessionTimeout = 26

RebalanceInProgress = 27

InvalidCommitOffsetSize = 28

TopicAuthorizationFailed = 29

GroupAuthorizationFailed = 30

ClusterAuthorizationFailed = 31

InvalidTimestamp = 32

UnsupportedSaslMechanism = 33

IllegalSaslState = 34

UnsupportedVersion = 35

TopicAlreadyExists = 36

InvalidPartitions = 37

InvalidReplicationFactor = 38

InvalidReplicaAssignment = 39

InvalidConfig = 40

NotController = 41

InvalidRequest = 42

UnsupportedForMessageFormat = 43

PolicyViolation = 44

OutOfOrderSequenceNumber = 45

DuplicateSequenceNumber = 46

InvalidProducerEpoch = 47

InvalidTxnState = 48

InvalidProducerIdMapping = 49

InvalidTransactionTimeout = 50

ConcurrentTransactions = 51

TransactionCoordinatorFenced = 52

TransactionalIdAuthorizationFailed = 53

SecurityDisabled = 54

OperationNotAttempted = 55

KafkaStorageError = 56

LogDirNotFound = 57

SaslAuthenticationFailed = 58

UnknownProducerId = 59

ReassignmentInProgress = 60

DelegationTokenAuthDisabled = 61

DelegationTokenNotFound = 62

DelegationTokenOwnerMismatch = 63

DelegationTokenRequestNotAllowed = 64

DelegationTokenAuthorizationFailed = 65

DelegationTokenExpired = 66

InvalidPrincipleType = 67

NonEmptyGroup = 68

GroupIdNotFound = 69

FetchSessionIdNotFound = 70

InvalidFetchSessionEpoch = 71

ListenerNotFound = 72

TopicDeletionDisabled = 73

FencedLeaderEpoch = 74

UnknownLeaderEpoch = 75

UnsupportedCompressionType = 76

StaleBrokerEpoch = 77

OffsetNotAvailable = 78

MemberIdRequired = 79

PreferredLeaderNotAvailable = 80

GroupMaxSizeReached = 81

Implementations

impl ErrorCode

pub fn is_ok(&self) -> bool

pub fn to_string(&self) -> String

pub fn to_sentence(&self) -> String

pub fn is_error(&self) -> bool

Trait Implementations

impl Clone for ErrorCode

fn clone(&self) -> ErrorCode

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ErrorCode

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

Formats the value using the given formatter.

impl Decoder for ErrorCode

fn decode<T>(&mut self, src: &mut T, version: Version) -> Result<(), Error>

where T: Buf,

fn decode_from<T>(src: &mut T, version: i16) -> Result<Self, Error>

where T: Buf, Self: Default,

decode Kafka compliant protocol values from buf

impl Default for ErrorCode

fn default() -> ErrorCode

Returns the “default value” for a type.

impl<'de> Deserialize<'de> for ErrorCode

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl Encoder for ErrorCode

fn encode<T>(&self, dest: &mut T, version: Version) -> Result<(), Error>

where T: BufMut,

encoding contents for buffer

fn write_size(&self, version: Version) -> usize

size of this object in bytes

fn as_bytes(&self, version: i16) -> Result<Bytes, Error>

impl PartialEq for ErrorCode

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

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl TryFrom<i16> for ErrorCode

type Error = Error

The type returned in the event of a conversion error.

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

Performs the conversion.

impl Copy for ErrorCode

impl StructuralPartialEq for ErrorCode