Enum rdkafka_sys::types::RDKafkaErrorCode
source · #[non_exhaustive]pub enum RDKafkaErrorCode {
Show 159 variants
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,
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,
}Expand description
Native rdkafka error code.
Variants (Non-exhaustive)§
This enum is marked as non-exhaustive
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.
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.
Trait Implementations§
source§impl Clone for RDKafkaErrorCode
impl Clone for RDKafkaErrorCode
source§fn clone(&self) -> RDKafkaErrorCode
fn clone(&self) -> RDKafkaErrorCode
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read moresource§impl Debug for RDKafkaErrorCode
impl Debug for RDKafkaErrorCode
source§impl Display for RDKafkaErrorCode
impl Display for RDKafkaErrorCode
source§impl Error for RDKafkaErrorCode
impl Error for RDKafkaErrorCode
1.30.0 · source§fn source(&self) -> Option<&(dyn Error + 'static)>
fn source(&self) -> Option<&(dyn Error + 'static)>
1.0.0 · source§fn description(&self) -> &str
fn description(&self) -> &str
source§impl From<rd_kafka_resp_err_t> for RDKafkaErrorCode
impl From<rd_kafka_resp_err_t> for RDKafkaErrorCode
source§fn from(err: RDKafkaRespErr) -> RDKafkaErrorCode
fn from(err: RDKafkaRespErr) -> RDKafkaErrorCode
source§impl PartialEq for RDKafkaErrorCode
impl PartialEq for RDKafkaErrorCode
source§fn eq(&self, other: &RDKafkaErrorCode) -> bool
fn eq(&self, other: &RDKafkaErrorCode) -> bool
self and other values to be equal, and is used
by ==.