Enum ConsumerError 

pub enum ConsumerError {
    ThreadStoppedBefore {
        operation: &'static str,
    },
    ThreadStoppedDuring {
        operation: &'static str,
    },
    Join(JoinError),
    EmptySubscription,
    EmptySubscriptionPattern,
    InvalidSubscriptionRegex {
        message: String,
    },
    ConcurrentPoll,
    Wakeup,
    InvalidSeekOffset {
        offset: i64,
    },
    EmptyTopicPartition,
    PartitionNotAssigned {
        operation: &'static str,
        topic: String,
        partition: i32,
    },
    InvalidRegularExpression {
        message: String,
    },
    UnsupportedAssignor {
        assignor: String,
        message: String,
    },
    UnreleasedInstanceId {
        instance_id: String,
        message: String,
    },
    FencedInstanceId {
        instance_id: String,
        message: String,
    },
    ShuttingDown,
    Fatal {
        message: String,
    },
}

Errors raised by the consumer API.

Variants

ThreadStoppedBefore

The runtime stopped before the operation was sent.

Fields

operation: &'static str

Operation that was waiting to be sent.

ThreadStoppedDuring

The runtime stopped while the operation was waiting for a reply.

Fields

operation: &'static str

Operation that was in flight.

Join(JoinError)

The background consumer task could not be joined.

EmptySubscription

A subscription was requested without any topic names.

EmptySubscriptionPattern

A regex subscription was requested with an empty pattern.

InvalidSubscriptionRegex

A regex subscription could not be compiled locally.

Fields

message: String

Regex parser error message.

ConcurrentPoll

Another poll call was already active.

Wakeup

A blocking poll was interrupted with wakeup.

InvalidSeekOffset

A seek offset was negative.

Fields

offset: i64

Requested offset.

EmptyTopicPartition

A topic partition had an empty topic name.

PartitionNotAssigned

The operation needs a partition currently assigned to this consumer.

Fields

operation: &'static str

Operation that needed the assignment.

topic: String

Topic name.

partition: i32

Partition number.

InvalidRegularExpression

The broker rejected the subscription regex.

Fields

message: String

Broker error message.

UnsupportedAssignor

The broker rejected the configured server-side assignor.

Fields

assignor: String

Requested assignor name.

message: String

Broker error message.

UnreleasedInstanceId

A static member id is still owned by another consumer instance.

Fields

instance_id: String

Static member instance id.

message: String

Broker error message.

FencedInstanceId

The broker fenced this static member instance.

Fields

instance_id: String

Static member instance id.

message: String

Broker error message.

ShuttingDown

The consumer runtime is already shutting down.

Fatal

The consumer runtime is in a fatal state.

Fields

message: String

Fatal state reason.

Trait Implementations

impl Debug for ConsumerError

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

Formats the value using the given formatter.

impl Display for ConsumerError

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

Formats the value using the given formatter.

impl Error for ConsumerError

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.

impl From<ConsumerError> for Error

fn from(source: ConsumerError) -> Self

Converts to this type from the input type.