Enum kf_protocol_api::ErrorCode

#[repr(i16)]pub enum ErrorCode {
    UnknownServerError,
    None,
    OffsetOutOfRange,
    CorruptMessage,
    UnknownTopicOrPartition,
    InvalidFetchSize,
    LeaderNotAvailable,
    NotLeaderForPartition,
    RequestTimedOut,
    BrokerNotAvailable,
    ReplicaNotAvailable,
    MessageTooLarge,
    StaleControllerEpoch,
    OffsetMetadataTooLarge,
    NetworkException,
    CoordinatorLoadInProgress,
    CoordinatorNotAvailable,
    NotCoordinator,
    InvalidTopicException,
    RecordListTooLarge,
    NotEnoughReplicas,
    NotEnougReplicasAfterAppend,
    InvalidRequiredAcks,
    IllegalGeneration,
    InconsistentGroupProtocol,
    InvalidGroupId,
    UnknownMemberId,
    InvalidSessionTimeout,
    RebalanceInProgress,
    InvalidCommitOffsetSize,
    TopicAuthorizationFailed,
    GroupAuthorizationFailed,
    ClusterAuthorizationFailed,
    InvalidTimestamp,
    UnsupportedSaslMechanism,
    IllegalSaslState,
    UnsupportedVersion,
    TopicAlreadyExists,
    InvalidPartitions,
    InvalidReplicationFactor,
    InvalidReplicaAssignment,
    InvalidConfig,
    NotController,
    InvalidRequest,
    UnsupportedForMessageFormat,
    PolicyViolation,
    OutOfOrderSequenceNumber,
    DuplicateSequenceNumber,
    InvalidProducerEpoch,
    InvalidTxnState,
    InvalidProducerIdMapping,
    InvalidTransactionTimeout,
    ConcurrentTransactions,
    TransactionCoordinatorFenced,
    TransactionalIdAuthorizationFailed,
    SecurityDisabled,
    OperationNotAttempted,
    KafkaStorageError,
    LogDirNotFound,
    SaslAuthenticationFailed,
    UnknownProducerId,
    ReassignmentInProgress,
    DelegationTokenAuthDisabled,
    DelegationTokenNotFound,
    DelegationTokenOwnerMismatch,
    DelegationTokenRequestNotAllowed,
    DelegationTokenAuthorizationFailed,
    DelegationTokenExpired,
    InvalidPrincipleType,
    NonEmptyGroup,
    GroupIdNotFound,
    FetchSessionIdNotFound,
    InvalidFetchSessionEpoch,
    ListenerNotFound,
    TopicDeletionDisabled,
    FencedLeaderEpoch,
    UnknownLeaderEpoch,
    UnsupportedCompressionType,
    StaleBrokerEpoch,
    OffsetNotAvailable,
    MemberIdRequired,
    PreferredLeaderNotAvailable,
    GroupMaxSizeReached,
}

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

Variants

UnknownServerError

None

OffsetOutOfRange

CorruptMessage

UnknownTopicOrPartition

InvalidFetchSize

LeaderNotAvailable

NotLeaderForPartition

RequestTimedOut

BrokerNotAvailable

ReplicaNotAvailable

MessageTooLarge

StaleControllerEpoch

OffsetMetadataTooLarge

NetworkException

CoordinatorLoadInProgress

CoordinatorNotAvailable

NotCoordinator

InvalidTopicException

RecordListTooLarge

NotEnoughReplicas

NotEnougReplicasAfterAppend

InvalidRequiredAcks

IllegalGeneration

InconsistentGroupProtocol

InvalidGroupId

UnknownMemberId

InvalidSessionTimeout

RebalanceInProgress

InvalidCommitOffsetSize

TopicAuthorizationFailed

GroupAuthorizationFailed

ClusterAuthorizationFailed

InvalidTimestamp

UnsupportedSaslMechanism

IllegalSaslState

UnsupportedVersion

TopicAlreadyExists

InvalidPartitions

InvalidReplicationFactor

InvalidReplicaAssignment

InvalidConfig

NotController

InvalidRequest

UnsupportedForMessageFormat

PolicyViolation

OutOfOrderSequenceNumber

DuplicateSequenceNumber

InvalidProducerEpoch

InvalidTxnState

InvalidProducerIdMapping

InvalidTransactionTimeout

ConcurrentTransactions

TransactionCoordinatorFenced

TransactionalIdAuthorizationFailed

SecurityDisabled

OperationNotAttempted

KafkaStorageError

LogDirNotFound

SaslAuthenticationFailed

UnknownProducerId

ReassignmentInProgress

DelegationTokenAuthDisabled

DelegationTokenNotFound

DelegationTokenOwnerMismatch

DelegationTokenRequestNotAllowed

DelegationTokenAuthorizationFailed

DelegationTokenExpired

InvalidPrincipleType

NonEmptyGroup

GroupIdNotFound

FetchSessionIdNotFound

InvalidFetchSessionEpoch

ListenerNotFound

TopicDeletionDisabled

FencedLeaderEpoch

UnknownLeaderEpoch

UnsupportedCompressionType

StaleBrokerEpoch

OffsetNotAvailable

MemberIdRequired

PreferredLeaderNotAvailable

GroupMaxSizeReached

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 Copy for ErrorCode

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
    Self: Default,
    T: Buf, 

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<ErrorCode> for ErrorCode

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

This method tests for self and other values to be equal, and is used by ==.

#[must_use]fn ne(&self, other: &Rhs) -> bool

This method tests for !=.

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 StructuralPartialEq for ErrorCode

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.