Enum rdkafka::error::KafkaError
source · [−]#[non_exhaustive]
pub enum KafkaError {
Show 22 variants
AdminOpCreation(String),
AdminOp(RDKafkaErrorCode),
Canceled,
ClientConfig(RDKafkaConfRes, String, String, String),
ClientCreation(String),
ConsumerCommit(RDKafkaErrorCode),
Flush(RDKafkaErrorCode),
Global(RDKafkaErrorCode),
GroupListFetch(RDKafkaErrorCode),
MessageConsumption(RDKafkaErrorCode),
MessageProduction(RDKafkaErrorCode),
MetadataFetch(RDKafkaErrorCode),
NoMessageReceived,
Nul(NulError),
OffsetFetch(RDKafkaErrorCode),
PartitionEOF(i32),
PauseResume(String),
Seek(String),
SetPartitionOffset(RDKafkaErrorCode),
StoreOffset(RDKafkaErrorCode),
Subscription(String),
Transaction(RDKafkaError),
}
Expand description
Represents all possible Kafka errors.
If applicable, check the underlying RDKafkaErrorCode
to get details.
Variants (Non-exhaustive)
This enum is marked as non-exhaustive
AdminOpCreation(String)
Creation of admin operation failed.
AdminOp(RDKafkaErrorCode)
The admin operation itself failed.
Canceled
The client was dropped before the operation completed.
ClientConfig(RDKafkaConfRes, String, String, String)
Invalid client configuration.
ClientCreation(String)
Client creation failed.
ConsumerCommit(RDKafkaErrorCode)
Consumer commit failed.
Flush(RDKafkaErrorCode)
Flushing failed
Global(RDKafkaErrorCode)
Global error.
GroupListFetch(RDKafkaErrorCode)
Group list fetch failed.
MessageConsumption(RDKafkaErrorCode)
Message consumption failed.
MessageProduction(RDKafkaErrorCode)
Message production error.
MetadataFetch(RDKafkaErrorCode)
Metadata fetch error.
NoMessageReceived
No message was received.
Nul(NulError)
Unexpected null pointer
OffsetFetch(RDKafkaErrorCode)
Offset fetch failed.
PartitionEOF(i32)
End of partition reached.
PauseResume(String)
Pause/Resume failed.
Seek(String)
Seeking a partition failed.
SetPartitionOffset(RDKafkaErrorCode)
Setting partition offset failed.
StoreOffset(RDKafkaErrorCode)
Offset store failed.
Subscription(String)
Subscription creation failed.
Transaction(RDKafkaError)
Transaction error.
Implementations
Returns the RDKafkaErrorCode
underlying this error, if any.
Trait Implementations
Performs the conversion.
This method tests for self
and other
values to be equal, and is used
by ==
. Read more
This method tests for !=
.
Auto Trait Implementations
impl RefUnwindSafe for KafkaError
impl Send for KafkaError
impl Sync for KafkaError
impl Unpin for KafkaError
impl UnwindSafe for KafkaError
Blanket Implementations
Mutably borrows from an owned value. Read more