Enum ProxyError 

pub enum ProxyError {
    Connection(Error),
    ProtocolDecode {
        message: String,
    },
    ProtocolEncode {
        message: String,
    },
    BrokerUnavailable {
        broker_id: i32,
        message: String,
    },
    NoBrokersAvailable,
    TopicNotFound {
        topic: String,
    },
    PartitionOutOfRange {
        topic: String,
        partition: i32,
        max_partition: i32,
    },
    OffsetOverflow {
        partition: i32,
        offset: i64,
    },
    CorrelationIdMismatch {
        expected: i32,
        actual: i32,
    },
    UnsupportedApi {
        api_key: i16,
        api_version: i16,
    },
    Remap(RemapError),
    Tls(TlsError),
    Auth(AuthError),
    Shutdown,
}

Errors that occur during proxy operation.

Variants

Connection(Error)

TCP/IO connection error.

ProtocolDecode

Failed to decode Kafka protocol message.

Fields

message: String

ProtocolEncode

Failed to encode Kafka protocol message.

Fields

message: String

BrokerUnavailable

Broker is not available or connection failed.

Fields

broker_id: i32

message: String

NoBrokersAvailable

No brokers available to handle request.

TopicNotFound

Topic was not found in metadata.

Fields

topic: String

PartitionOutOfRange

Partition index out of valid range.

Fields

topic: String

partition: i32

max_partition: i32

OffsetOverflow

Offset would overflow the configured range.

Fields

partition: i32

offset: i64

CorrelationIdMismatch

Request correlation ID mismatch.

Fields

expected: i32

actual: i32

UnsupportedApi

Unsupported API key/version.

Fields

api_key: i16

api_version: i16

Remap(RemapError)

Remapping error.

Tls(TlsError)

TLS error.

Auth(AuthError)

SASL authentication error.

Shutdown

Shutdown signal received.

Trait Implementations

impl Debug for ProxyError

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

Formats the value using the given formatter.

impl Display for ProxyError

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

Formats the value using the given formatter.

impl Error for ProxyError

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<AuthError> for ProxyError

fn from(source: AuthError) -> Self

Converts to this type from the input type.

impl From<Error> for ProxyError

fn from(source: Error) -> Self

Converts to this type from the input type.

impl From<RemapError> for ProxyError

fn from(source: RemapError) -> Self

Converts to this type from the input type.

impl From<TlsError> for ProxyError

fn from(source: TlsError) -> Self

Converts to this type from the input type.