Struct ConsumerLogTruncationError 

pub struct ConsumerLogTruncationError { /* private fields */ }

Log truncation was detected: the broker’s log diverges from the offsets the consumer had fetched.

Corresponds to Java’s LogTruncationException. It has no entry in Errors, so it carries no protocol code.

Java extends chain: LogTruncationException -> OffsetOutOfRangeException -> InvalidOffsetException -> KafkaException

The OffsetOutOfRangeException in that chain is the consumer package’s, so this is a ConsumerOffsetOutOfRangeError too — which is why it carries the same offset_out_of_range_partitions map.

Implementations

impl ConsumerLogTruncationError

pub fn new( offset_out_of_range_partitions: HashMap<TopicPartition, i64>, divergent_offsets: HashMap<TopicPartition, OffsetAndMetadata>, ) -> Self

Mirrors Java’s LogTruncationException(Map<TopicPartition, Long>, Map<TopicPartition, OffsetAndMetadata>), which composes the message from the divergent offsets: "Truncated partitions detected with divergent offsets " + divergentOffsets.

pub fn with_message( message: impl Into<String>, offset_out_of_range_partitions: HashMap<TopicPartition, i64>, divergent_offsets: HashMap<TopicPartition, OffsetAndMetadata>, ) -> Self

Mirrors Java’s three-argument LogTruncationException(String, Map<TopicPartition, Long>, Map<TopicPartition, OffsetAndMetadata>).

pub fn offset_out_of_range_partitions(&self) -> &HashMap<TopicPartition, i64>

The out-of-range offset per partition.

pub fn divergent_offsets(&self) -> &HashMap<TopicPartition, OffsetAndMetadata>

The divergent offset per partition.

pub fn partitions(&self) -> impl Iterator<Item = &TopicPartition>

The partitions this error covers.

LogTruncationException does not override OffsetOutOfRangeException.partitions() (OffsetOutOfRangeException.java:51-54), so this is the key set of offset_out_of_range_partitions — NOT of divergent_offsets. The distinction is the whole point of the accessor: Java’s javadoc (LogTruncationException.java:48-56) tells the caller to iterate partitions() and then look each one up in divergentOffsets(), “because there is no guarantee that this offset will be known” for every truncated partition.

Returns an iterator rather than a HashSet for the same reason as ConsumerOffsetOutOfRangeError::partitions: Java’s keySet() is a view, not a copy.

pub fn message(&self) -> &str

The error message.

impl ConsumerLogTruncationError

pub fn source(&self) -> Option<&Error>

Always None: LogTruncationException exposes no Throwable cause constructor, so its cause is null in Java too. Present as an inherent method so it shadows both ErrorSource::source and std::error::Error::source, keeping x.source() unambiguous and typed.

Trait Implementations

impl Clone for ConsumerLogTruncationError

fn clone(&self) -> ConsumerLogTruncationError

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Debug for ConsumerLogTruncationError

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Display for ConsumerLogTruncationError

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Error for ConsumerLogTruncationError

fn source(&self) -> Option<&(dyn Error + 'static)>

Returns the lower-level source of this error, if any.

fn description(&self) -> &str

👎Deprecated since 1.42.0: use the Display impl or to_string()

fn cause(&self) -> Option<&dyn Error>

👎Deprecated since 1.33.0: replaced by Error::source, which can support downcasting

fn provide<'a>(&'a self, request: &mut Request<'a>)

🔬This is a nightly-only experimental API. (error_generic_member_access)

Provides type-based access to context intended for error reports.