Enum rdkafka::error::RDKafkaErrorCode

#[non_exhaustive]
pub enum RDKafkaErrorCode {
    BadMessage = -199,
    BadCompression = -198,
    BrokerDestroy = -197,
    Fail = -196,
    BrokerTransportFailure = -195,
    CriticalSystemResource = -194,
    Resolve = -193,
    MessageTimedOut = -192,
    PartitionEOF = -191,
    UnknownPartition = -190,
    FileSystem = -189,
    UnknownTopic = -188,
    AllBrokersDown = -187,
    InvalidArgument = -186,
    OperationTimedOut = -185,
    QueueFull = -184,
    ISRInsufficient = -183,
    NodeUpdate = -182,
    SSL = -181,
    WaitingForCoordinator = -180,
    UnknownGroup = -179,
    InProgress = -178,
    PreviousInProgress = -177,
    ExistingSubscription = -176,
    AssignPartitions = -175,
    RevokePartitions = -174,
    Conflict = -173,
    State = -172,
    UnknownProtocol = -171,
    NotImplemented = -170,
    Authentication = -169,
    NoOffset = -168,
    Outdated = -167,
    TimedOutQueue = -166,
    UnsupportedFeature = -165,
    WaitCache = -164,
    Interrupted = -163,
    KeySerialization = -162,
    ValueSerialization = -161,
    KeyDeserialization = -160,
    ValueDeserialization = -159,
    Partial = -158,
    ReadOnly = -157,
    NoEnt = -156,
    Underflow = -155,
    InvalidType = -154,
    Retry = -153,
    PurgeQueue = -152,
    PurgeInflight = -151,
    Fatal = -150,
    Inconsistent = -149,
    GaplessGuarantee = -148,
    PollExceeded = -147,
    UnknownBroker = -146,
    NotConfigured = -145,
    Fenced = -144,
    Application = -143,
    AssignmentLost = -142,
    Noop = -141,
    AutoOffsetReset = -140,
    LogTruncation = -139,
    InvalidDifferentRecord = -138,
    Unknown = -1,
    NoError = 0,
    OffsetOutOfRange = 1,
    InvalidMessage = 2,
    UnknownTopicOrPartition = 3,
    InvalidMessageSize = 4,
    LeaderNotAvailable = 5,
    NotLeaderForPartition = 6,
    RequestTimedOut = 7,
    BrokerNotAvailable = 8,
    ReplicaNotAvailable = 9,
    MessageSizeTooLarge = 10,
    StaleControllerEpoch = 11,
    OffsetMetadataTooLarge = 12,
    NetworkException = 13,
    CoordinatorLoadInProgress = 14,
    CoordinatorNotAvailable = 15,
    NotCoordinator = 16,
    InvalidTopic = 17,
    MessageBatchTooLarge = 18,
    NotEnoughReplicas = 19,
    NotEnoughReplicasAfterAppend = 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,
    InvalidTransactionalState = 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,
    InvalidPrincipalType = 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,
    FencedInstanceId = 82,
    EligibleLeadersNotAvailable = 83,
    ElectionNotNeeded = 84,
    NoReassignmentInProgress = 85,
    GroupSubscribedToTopic = 86,
    InvalidRecord = 87,
    UnstableOffsetCommit = 88,
    ThrottlingQuotaExceeded = 89,
    ProducerFenced = 90,
    ResourceNotFound = 91,
    DuplicateResource = 92,
    UnacceptableCredential = 93,
    InconsistentVoterSet = 94,
    InvalidUpdateVersion = 95,
    FeatureUpdateFailed = 96,
    PrincipalDeserializationFailure = 97,
    UnknownTopicId = 100,
    FencedMemberEpoch = 110,
    UnreleasedInstanceId = 111,
    UnsupportedAssignor = 112,
    StaleMemberEpoch = 113,
    UnknownSubscriptionId = 117,
    TelemetryTooLarge = 118,
}

Native rdkafka error code.

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.

BadMessage = -199

Received message is incorrect.

BadCompression = -198

Bad/unknown compression.

BrokerDestroy = -197

Broker is going away.

Fail = -196

Generic failure.

BrokerTransportFailure = -195

Broker transport failure.

CriticalSystemResource = -194

Critical system resource.

Resolve = -193

Failed to resolve broker.

MessageTimedOut = -192

Produced message timed out.

PartitionEOF = -191

Reached the end of the topic+partition queue on the broker. Not really an error.

UnknownPartition = -190

Permanent: Partition does not exist in cluster.

FileSystem = -189

File or filesystem error.

UnknownTopic = -188

Permanent: Topic does not exist in cluster.

AllBrokersDown = -187

All broker connections are down.

InvalidArgument = -186

Invalid argument, or invalid configuration.

OperationTimedOut = -185

Operation timed out.

QueueFull = -184

Queue is full.

ISRInsufficient = -183

ISR count < required.acks.

NodeUpdate = -182

Broker node update.

SSL = -181

SSL error.

WaitingForCoordinator = -180

Waiting for coordinator to become available.

UnknownGroup = -179

Unknown client group.

InProgress = -178

Operation in progress.

PreviousInProgress = -177

Previous operation in progress, wait for it to finish.

ExistingSubscription = -176

This operation would interfere with an existing subscription.

AssignPartitions = -175

Assigned partitions (rebalance_cb).

RevokePartitions = -174

Revoked partitions (rebalance_cb).

Conflict = -173

Conflicting use.

State = -172

Wrong state.

UnknownProtocol = -171

Unknown protocol.

NotImplemented = -170

Not implemented.

Authentication = -169

Authentication failure.

NoOffset = -168

No stored offset.

Outdated = -167

Outdated.

TimedOutQueue = -166

Timed out in queue.

UnsupportedFeature = -165

Feature not supported by broker.

WaitCache = -164

Awaiting cache update.

Interrupted = -163

Operation interrupted (e.g., due to yield).

KeySerialization = -162

Key serialization error.

ValueSerialization = -161

Value serialization error.

KeyDeserialization = -160

Key deserialization error.

ValueDeserialization = -159

Value deserialization error.

Partial = -158

Partial response.

ReadOnly = -157

Modification attempted on read-only object.

NoEnt = -156

No such entry or item not found.

Underflow = -155

Read underflow.

InvalidType = -154

Invalid type.

Retry = -153

Retry operation.

PurgeQueue = -152

Purged in queue.

PurgeInflight = -151

Purged in flight.

Fatal = -150

Fatal error: see rd_kafka_fatal_error().

Inconsistent = -149

Inconsistent state.

GaplessGuarantee = -148

Gap-less ordering would not be guaranteed if proceeding.

PollExceeded = -147

Maximum poll interval exceeded.

UnknownBroker = -146

Unknown broker.

NotConfigured = -145

Functionality not configured.

Fenced = -144

Instance has been fenced.

Application = -143

Application generated error.

AssignmentLost = -142

Assignment lost.

Noop = -141

No operation performed.

AutoOffsetReset = -140

No offset to automatically reset to.

LogTruncation = -139

Partition log truncation detected

InvalidDifferentRecord = -138

A different record in the batch was invalid and this message failed persisting.

Unknown = -1

Unknown broker error.

NoError = 0

Success.

OffsetOutOfRange = 1

Offset out of range.

InvalidMessage = 2

Invalid message.

UnknownTopicOrPartition = 3

Unknown topic or partition.

InvalidMessageSize = 4

Invalid message size.

LeaderNotAvailable = 5

Leader not available.

NotLeaderForPartition = 6

Not leader for partition.

RequestTimedOut = 7

Request timed out.

BrokerNotAvailable = 8

Broker not available.

ReplicaNotAvailable = 9

Replica not available.

MessageSizeTooLarge = 10

Message size too large.

StaleControllerEpoch = 11

Stale controller epoch code.

OffsetMetadataTooLarge = 12

Offset metadata string too large.

NetworkException = 13

Broker disconnected before response received.

CoordinatorLoadInProgress = 14

Coordinator load in progress.

CoordinatorNotAvailable = 15

Coordinator not available.

NotCoordinator = 16

Not coordinator.

InvalidTopic = 17

Invalid topic.

MessageBatchTooLarge = 18

Message batch larger than configured server segment size.

NotEnoughReplicas = 19

Not enough in-sync replicas.

NotEnoughReplicasAfterAppend = 20

Message(s) written to insufficient number of in-sync replicas.

InvalidRequiredAcks = 21

Invalid required acks value.

IllegalGeneration = 22

Specified group generation id is not valid.

InconsistentGroupProtocol = 23

Inconsistent group protocol.

InvalidGroupId = 24

Invalid group.id.

UnknownMemberId = 25

Unknown member.

InvalidSessionTimeout = 26

Invalid session timeout.

RebalanceInProgress = 27

Group rebalance in progress.

InvalidCommitOffsetSize = 28

Commit offset data size is not valid.

TopicAuthorizationFailed = 29

Topic authorization failed.

GroupAuthorizationFailed = 30

Group authorization failed.

ClusterAuthorizationFailed = 31

Cluster authorization failed.

InvalidTimestamp = 32

Invalid timestamp.

UnsupportedSASLMechanism = 33

Unsupported SASL mechanism.

IllegalSASLState = 34

Illegal SASL state.

UnsupportedVersion = 35

Unsupported version.

TopicAlreadyExists = 36

Topic already exists.

InvalidPartitions = 37

Invalid number of partitions.

InvalidReplicationFactor = 38

Invalid replication factor.

InvalidReplicaAssignment = 39

Invalid replica assignment.

InvalidConfig = 40

Invalid config.

NotController = 41

Not controller for cluster.

InvalidRequest = 42

Invalid request.

UnsupportedForMessageFormat = 43

Message format on broker does not support request.

PolicyViolation = 44

Policy violation.

OutOfOrderSequenceNumber = 45

Broker received an out of order sequence number.

DuplicateSequenceNumber = 46

Broker received a duplicate sequence number.

InvalidProducerEpoch = 47

Producer attempted an operation with an old epoch.

InvalidTransactionalState = 48

Producer attempted a transactional operation in an invalid state.

InvalidProducerIdMapping = 49

Producer attempted to use a producer id which is currently assigned to its transactional id.

InvalidTransactionTimeout = 50

Transaction timeout is larger than the maxi value allowed by the broker’s max.transaction.timeout.ms.

ConcurrentTransactions = 51

Producer attempted to update a transaction while another concurrent operation on the same transaction was ongoing.

TransactionCoordinatorFenced = 52

Indicates that the transaction coordinator sending a WriteTxnMarker is no longer the current coordinator for a given producer.

TransactionalIdAuthorizationFailed = 53

Transactional Id authorization failed.

SecurityDisabled = 54

Security features are disabled.

OperationNotAttempted = 55

Operation not attempted.

KafkaStorageError = 56

Disk error when trying to access log file on the disk.

LogDirNotFound = 57

The user-specified log directory is not found in the broker config.

SaslAuthenticationFailed = 58

SASL Authentication failed.

UnknownProducerId = 59

Unknown Producer Id.

ReassignmentInProgress = 60

Partition reassignment is in progress.

DelegationTokenAuthDisabled = 61

Delegation Token feature is not enabled.

DelegationTokenNotFound = 62

Delegation Token is not found on server.

DelegationTokenOwnerMismatch = 63

Specified Principal is not valid Owner/Renewer.

DelegationTokenRequestNotAllowed = 64

Delegation Token requests are not allowed on this connection.

DelegationTokenAuthorizationFailed = 65

Delegation Token authorization failed.

DelegationTokenExpired = 66

Delegation Token is expired.

InvalidPrincipalType = 67

Supplied principalType is not supported.

NonEmptyGroup = 68

The group is not empty.

GroupIdNotFound = 69

The group id does not exist.

FetchSessionIdNotFound = 70

The fetch session ID was not found.

InvalidFetchSessionEpoch = 71

The fetch session epoch is invalid.

ListenerNotFound = 72

No matching listener.

TopicDeletionDisabled = 73

Topic deletion is disabled.

FencedLeaderEpoch = 74

Leader epoch is older than broker epoch.

UnknownLeaderEpoch = 75

Leader epoch is newer than broker epoch.

UnsupportedCompressionType = 76

Unsupported compression type.

StaleBrokerEpoch = 77

Broker epoch has changed.

OffsetNotAvailable = 78

Leader high watermark is not caught up.

MemberIdRequired = 79

Group member needs a valid member ID.

PreferredLeaderNotAvailable = 80

Preferred leader was not available.

GroupMaxSizeReached = 81

Consumer group has reached maximum size.

FencedInstanceId = 82

Static consumer fenced by other consumer with same group.instance.id.

EligibleLeadersNotAvailable = 83

Eligible partition leaders are not available.

ElectionNotNeeded = 84

Leader election not needed for topic partition.

NoReassignmentInProgress = 85

No partition reassignment is in progress.

GroupSubscribedToTopic = 86

Deleting offsets of a topic while the consumer group is subscribed to it.

InvalidRecord = 87

Broker failed to validate record.

UnstableOffsetCommit = 88

There are unstable offsets that need to be cleared.

ThrottlingQuotaExceeded = 89

Throttling quota has been exceeded.

ProducerFenced = 90

There is a newer producer with the same transactional ID which fences the current one.

ResourceNotFound = 91

Request illegally referred to resource that does not exist.

DuplicateResource = 92

Request illegally referred to the same resource twice.

UnacceptableCredential = 93

Requested credential would not meet criteria for acceptability.

InconsistentVoterSet = 94

Either the sender or recipient of a voter-only request is not one of the expected voters.

InvalidUpdateVersion = 95

Invalid update version.

FeatureUpdateFailed = 96

Unable to update finalized features due to server error.

PrincipalDeserializationFailure = 97

Request principal deserialization failed during forwarding.

UnknownTopicId = 100

Unknown topic ID.

FencedMemberEpoch = 110

The member epoch is fenced by the group coordinator.

UnreleasedInstanceId = 111

The instance ID is still used by another member in the consumer group.

UnsupportedAssignor = 112

The assignor or its version range is not supported by the consumer group.

StaleMemberEpoch = 113

The member epoch is stale.

UnknownSubscriptionId = 117

The client sent a push telemetry request with an invalid or outdated subscription ID.

TelemetryTooLarge = 118

The client sent a push telemetry request larger than the maximum size that the broker will accept.

Trait Implementations

impl Clone for RDKafkaErrorCode

fn clone(&self) -> RDKafkaErrorCode

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for RDKafkaErrorCode

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

Formats the value using the given formatter.

impl Display for RDKafkaErrorCode

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

Formats the value using the given formatter.

impl Error for RDKafkaErrorCode

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0: use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0: replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.

impl From<rd_kafka_resp_err_t> for RDKafkaErrorCode

fn from(err: rd_kafka_resp_err_t) -> RDKafkaErrorCode

Converts to this type from the input type.

impl PartialEq for RDKafkaErrorCode

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

impl Eq for RDKafkaErrorCode

impl StructuralPartialEq for RDKafkaErrorCode