pub struct NotEnoughReplicasAfterAppendError { /* private fields */ }Expand description
Number of insync replicas for the partition is lower than min.insync.replicas This error is raised when the low ISR size is discovered after the message was already appended to the log. Producer retries will cause duplicates.
§Translation notes
Error code Errors::NotEnoughReplicasAfterAppend. Java extends chain:
NotEnoughReplicasAfterAppendException -> RetriableException -> ApiException ->
KafkaException.
Implementations§
Source§impl NotEnoughReplicasAfterAppendError
impl NotEnoughReplicasAfterAppendError
Sourcepub fn new(message: impl Into<String>) -> Self
pub fn new(message: impl Into<String>) -> Self
Create the error with the given message and no cause,
mirroring Java’s (String message) constructor.
This keeps the plain name under CLAUDE.md §2: the dominant Java
shape among the classes this macro declares is
(String message) + (String message, Throwable cause), whose
parameter-name intersection is {message} — matched exactly by
(String message).
Sourcepub fn with_source(message: impl Into<String>, source: Error) -> Self
pub fn with_source(message: impl Into<String>, source: Error) -> Self
Create the error with the given message and an underlying cause,
mirroring Java’s (String message, Throwable cause) constructor.
Suffixed with the one parameter beyond the {message}
intersection (CLAUDE.md §2) — see new.
Sourcepub fn with_default_message() -> Self
pub fn with_default_message() -> Self
Create the error with the default message for its error code,
mirroring Java’s Errors.exception().
Not a constructor overload, so CLAUDE.md §2’s suffixing does not
apply: it translates the Errors static factory, which fills in
Errors.message() and has no Java constructor counterpart.
Trait Implementations§
Source§impl Clone for NotEnoughReplicasAfterAppendError
impl Clone for NotEnoughReplicasAfterAppendError
Source§fn clone(&self) -> NotEnoughReplicasAfterAppendError
fn clone(&self) -> NotEnoughReplicasAfterAppendError
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read more