pub struct ConsumerRetriableCommitFailedError { /* private fields */ }Expand description
Error returned when an offset commit fails with a retriable error. This error is generated on the client side upon receiving retriable error codes from the Group Coordinator in a commit response.
Unlike ConsumerCommitFailedError, this
error indicates that the commit can be retried. The consumer should attempt
to commit the offsets again.
Implementations§
Source§impl ConsumerRetriableCommitFailedError
impl ConsumerRetriableCommitFailedError
Sourcepub fn new(message: impl Into<String>) -> Self
pub fn new(message: impl Into<String>) -> Self
Constructs a new ConsumerRetriableCommitFailedError with the specified
detail message.
§Arguments
message- The detail message
Sourcepub fn with_default_message() -> Self
pub fn with_default_message() -> Self
Create the error with Java’s default message.
Sourcepub fn with_source(source: Error) -> Self
pub fn with_source(source: Error) -> Self
Constructs a new ConsumerRetriableCommitFailedError with the specified
cause.
§Arguments
source- The cause of the error, returned bySelf::source
Trait Implementations§
Source§impl Clone for ConsumerRetriableCommitFailedError
impl Clone for ConsumerRetriableCommitFailedError
Source§fn clone(&self) -> ConsumerRetriableCommitFailedError
fn clone(&self) -> ConsumerRetriableCommitFailedError
Returns a duplicate 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 Error for ConsumerRetriableCommitFailedError
impl Error for ConsumerRetriableCommitFailedError
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()
Auto Trait Implementations§
impl Freeze for ConsumerRetriableCommitFailedError
impl RefUnwindSafe for ConsumerRetriableCommitFailedError
impl Send for ConsumerRetriableCommitFailedError
impl Sync for ConsumerRetriableCommitFailedError
impl Unpin for ConsumerRetriableCommitFailedError
impl UnsafeUnpin for ConsumerRetriableCommitFailedError
impl UnwindSafe for ConsumerRetriableCommitFailedError
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