Struct InvalidTopicError 

pub struct InvalidTopicError { /* private fields */ }

The client has attempted to perform an operation on an invalid topic. For example the topic name is too long, contains invalid characters etc. This error is not retriable because the operation won’t suddenly become valid.

See also

• UnknownTopicOrPartitionError

Translation notes

Error code Errors::InvalidTopicError. Java extends chain: InvalidTopicException -> InvalidConfigurationException -> ApiException -> KafkaException.

Implementations

impl InvalidTopicError

pub fn new(invalid_topics: HashSet<String>) -> Self

Creates an invalid topic error with the message "Invalid topics: [<topics>]".

Arguments

• invalid_topics - the invalid topics

pub fn with_default_message() -> Self

Creates an invalid topic error with the default message of Errors::InvalidTopicError and an empty set of topics, as the broker’s error code is turned into an error.

pub fn with_message( invalid_topics: HashSet<String>, message: impl Into<String>, ) -> Self

Creates an invalid topic error carrying a custom message.

Arguments

• invalid_topics - the invalid topics
• message - the error’s message

pub fn kafka_error(&self) -> &KafkaError

Returns the embedded KafkaError base, holding the error code, message and source.

pub fn invalid_topics(&self) -> &HashSet<String>

Returns the set of invalid topics, empty when the error was not built from them.

impl InvalidTopicError

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

Returns the underlying cause, if any, held by the embedded KafkaError base: Java’s getCause().

Trait Implementations

impl Clone for InvalidTopicError

fn clone(&self) -> InvalidTopicError

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for InvalidTopicError

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

Formats the value using the given formatter.

impl Display for InvalidTopicError

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

Formats the value using the given formatter.

impl Error for InvalidTopicError

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.