pub struct UnknownProducerIdError { /* private fields */ }Expand description
This exception is raised by the broker if it could not locate the producer metadata associated with the producerId in question. This could happen if, for instance, the producer’s records were deleted because their retention time had elapsed. Once the last records of the producerId are removed, the producer’s metadata is removed from the broker, and future appends by the producer will return this exception.
Corresponds to Java’s UnknownProducerIdException, error code Errors::UnknownProducerId.
Java extends chain:
UnknownProducerIdException -> OutOfOrderSequenceException ->
ApiException -> KafkaException
Implementations§
Source§impl UnknownProducerIdError
impl UnknownProducerIdError
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 UnknownProducerIdError
impl Clone for UnknownProducerIdError
Source§fn clone(&self) -> UnknownProducerIdError
fn clone(&self) -> UnknownProducerIdError
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read more