pub enum KafkaAdapterError {
SubscribeTopic(KafkaError, String),
ReceiveMessage(KafkaError),
Commit(KafkaError, Option<i64>),
PublishMessage(KafkaError, String),
UnhandledKafkaException(KafkaError),
HeaderNotFound(String),
UnknownMessageType(String),
MessageParsing(String),
OffsetZeroMessage,
EmptyPayload,
UnknownException(String),
}
Variants§
SubscribeTopic(KafkaError, String)
ReceiveMessage(KafkaError)
Commit(KafkaError, Option<i64>)
PublishMessage(KafkaError, String)
UnhandledKafkaException(KafkaError)
HeaderNotFound(String)
UnknownMessageType(String)
MessageParsing(String)
OffsetZeroMessage
EmptyPayload
UnknownException(String)
Trait Implementations§
source§impl Clone for KafkaAdapterError
impl Clone for KafkaAdapterError
source§fn clone(&self) -> KafkaAdapterError
fn clone(&self) -> KafkaAdapterError
Returns a copy of the value. Read more
1.0.0 · source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
Performs copy-assignment from
source
. Read moresource§impl Debug for KafkaAdapterError
impl Debug for KafkaAdapterError
source§impl Display for KafkaAdapterError
impl Display for KafkaAdapterError
source§impl Error for KafkaAdapterError
impl Error for KafkaAdapterError
source§fn source(&self) -> Option<&(dyn Error + 'static)>
fn source(&self) -> Option<&(dyn Error + 'static)>
Returns the lower-level source of this error, if any. Read more
1.0.0 · source§fn description(&self) -> &str
fn description(&self) -> &str
👎Deprecated since 1.42.0: use the Display impl or to_string()
source§impl From<KafkaError> for KafkaAdapterError
impl From<KafkaError> for KafkaAdapterError
source§fn from(source: KafkaError) -> Self
fn from(source: KafkaError) -> Self
Converts to this type from the input type.
source§impl PartialEq for KafkaAdapterError
impl PartialEq for KafkaAdapterError
impl Eq for KafkaAdapterError
impl StructuralPartialEq for KafkaAdapterError
Auto Trait Implementations§
impl Freeze for KafkaAdapterError
impl RefUnwindSafe for KafkaAdapterError
impl Send for KafkaAdapterError
impl Sync for KafkaAdapterError
impl Unpin for KafkaAdapterError
impl UnwindSafe for KafkaAdapterError
Blanket Implementations§
source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
source§unsafe fn clone_to_uninit(&self, dst: *mut T)
unsafe fn clone_to_uninit(&self, dst: *mut T)
🔬This is a nightly-only experimental API. (
clone_to_uninit
)source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§impl<Q, K> Equivalent<K> for Q
impl<Q, K> Equivalent<K> for Q
source§fn equivalent(&self, key: &K) -> bool
fn equivalent(&self, key: &K) -> bool
Compare self to
key
and return true
if they are equal.