Struct LocalCallbackError 

pub struct LocalCallbackError { /* private fields */ }

An error raised by a callback written in another language.

Like Java’s java.lang runtime exceptions it sits beside KafkaException, not below it, so Error::is_kafka_error is false and the client wraps it exactly as Java wraps a listener’s foreign Throwable: the rebalance-listener path builds KafkaException("User rebalance callback throws an error") with this error as its source, Java’s getCause().

The opaque pointer lets the binding swap the original error back in: on receiving an error whose cause chain holds a LocalCallbackError, it reads the pointer back. Rust never dereferences the pointer. Built with new it does not own it either: the binding keeps the object alive for as long as it may be read. Built by the FFI with a release function, the error owns it: every clone shares it, and the release function runs once, when the last copy drops, on whatever task or thread drops it.

Implementations

impl LocalCallbackError

pub fn new(message: impl Into<String>, opaque: *mut c_void) -> Self

Creates the error with the foreign error’s text and the binding’s opaque pointer to it, which the error does not own.

Arguments

• message - the foreign error’s text, for the client’s logs
• opaque - the binding’s pointer to the foreign error, never dereferenced by Rust

pub fn message(&self) -> &str

Returns the foreign error’s text, as the binding reported it.

pub fn opaque(&self) -> *mut c_void

Returns the binding’s opaque pointer to the foreign error, exactly as given. An owned pointer stays valid while any copy of the error lives.

Trait Implementations

impl Clone for LocalCallbackError

fn clone(&self) -> LocalCallbackError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for LocalCallbackError

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

Formats the value using the given formatter.

impl Display for LocalCallbackError

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

Formats the value using the given formatter.

impl Error for LocalCallbackError

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.