Struct UnsupportedVersionError 

pub struct UnsupportedVersionError { /* private fields */ }

Indicates that a request API or version needed by the client is not supported by the broker. This is typically a fatal error as Kafka clients will downgrade request versions as needed except in cases where a needed feature is not available in old versions. Fatal errors can generally only be handled by closing the client instance, although in some cases it may be possible to continue without relying on the underlying feature. For example, when the producer is used with idempotence enabled, this error is fatal since the producer does not support reverting to weaker semantics. On the other hand, if this error is raised from KafkaConsumer::offsets_for_times, it would be possible to revert to alternative logic to set the consumer’s position.

Translation notes

Error code Errors::UnsupportedVersion. Java extends chain: UnsupportedVersionException -> InvalidConfigurationException -> ApiException -> KafkaException.

Java’s internal subclass UnsupportedProtocolFieldException is this same type with a different crate-private kind.

Implementations

impl UnsupportedVersionError

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).

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.

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.

pub fn message(&self) -> &str

The error message.

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

The underlying cause, if any. Mirrors Java’s getCause().

Trait Implementations

impl Clone for UnsupportedVersionError

fn clone(&self) -> UnsupportedVersionError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for UnsupportedVersionError

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

Formats the value using the given formatter.

impl Display for UnsupportedVersionError

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

Formats the value using the given formatter.

impl Error for UnsupportedVersionError

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.