Struct ErrorCode

pub struct ErrorCode { /* private fields */ }

Implementations

impl ErrorCode

pub fn code(&self) -> i16

pub fn message(&self) -> &'static str

pub fn retryable(&self) -> bool

impl ErrorCode

pub const UNKNOWN_SERVER_ERROR: Self

pub const NONE: Self

pub const OFFSET_OUT_OF_RANGE: Self

pub const CORRUPT_MESSAGE: Self

pub const UNKNOWN_TOPIC_OR_PARTITION: Self

pub const INVALID_FETCH_SIZE: Self

pub const LEADER_NOT_AVAILABLE: Self

pub const NOT_LEADER_OR_FOLLOWER: Self

pub const REQUEST_TIMED_OUT: Self

pub const BROKER_NOT_AVAILABLE: Self

pub const REPLICA_NOT_AVAILABLE: Self

pub const MESSAGE_TOO_LARGE: Self

pub const STALE_CONTROLLER_EPOCH: Self

pub const OFFSET_METADATA_TOO_LARGE: Self

pub const NETWORK_EXCEPTION: Self

pub const COORDINATOR_LOAD_IN_PROGRESS: Self

pub const COORDINATOR_NOT_AVAILABLE: Self

pub const NOT_COORDINATOR: Self

pub const INVALID_TOPIC_EXCEPTION: Self

pub const RECORD_LIST_TOO_LARGE: Self

pub const NOT_ENOUGH_REPLICAS: Self

pub const NOT_ENOUGH_REPLICAS_AFTER_APPEND: Self

pub const INVALID_REQUIRED_ACKS: Self

pub const ILLEGAL_GENERATION: Self

pub const INCONSISTENT_GROUP_PROTOCOL: Self

pub const INVALID_GROUP_ID: Self

pub const UNKNOWN_MEMBER_ID: Self

pub const INVALID_SESSION_TIMEOUT: Self

pub const REBALANCE_IN_PROGRESS: Self

pub const INVALID_COMMIT_OFFSET_SIZE: Self

pub const TOPIC_AUTHORIZATION_FAILED: Self

pub const GROUP_AUTHORIZATION_FAILED: Self

pub const CLUSTER_AUTHORIZATION_FAILED: Self

pub const INVALID_TIMESTAMP: Self

pub const UNSUPPORTED_SASL_MECHANISM: Self

pub const ILLEGAL_SASL_STATE: Self

pub const UNSUPPORTED_VERSION: Self

pub const TOPIC_ALREADY_EXISTS: Self

pub const INVALID_PARTITIONS: Self

pub const INVALID_REPLICATION_FACTOR: Self

pub const INVALID_REPLICA_ASSIGNMENT: Self

pub const INVALID_CONFIG: Self

pub const NOT_CONTROLLER: Self

pub const INVALID_REQUEST: Self

pub const UNSUPPORTED_FOR_MESSAGE_FORMAT: Self

pub const POLICY_VIOLATION: Self

pub const OUT_OF_ORDER_SEQUENCE_NUMBER: Self

pub const DUPLICATE_SEQUENCE_NUMBER: Self

pub const INVALID_PRODUCER_EPOCH: Self

pub const INVALID_TXN_STATE: Self

pub const INVALID_PRODUCER_ID_MAPPING: Self

pub const INVALID_TRANSACTION_TIMEOUT: Self

pub const CONCURRENT_TRANSACTIONS: Self

pub const TRANSACTION_COORDINATOR_FENCED: Self

pub const TRANSACTIONAL_ID_AUTHORIZATION_FAILED: Self

pub const SECURITY_DISABLED: Self

pub const OPERATION_NOT_ATTEMPTED: Self

pub const KAFKA_STORAGE_ERROR: Self

pub const LOG_DIR_NOT_FOUND: Self

pub const SASL_AUTHENTICATION_FAILED: Self

pub const UNKNOWN_PRODUCER_ID: Self

pub const REASSIGNMENT_IN_PROGRESS: Self

pub const DELEGATION_TOKEN_AUTH_DISABLED: Self

pub const DELEGATION_TOKEN_NOT_FOUND: Self

pub const DELEGATION_TOKEN_OWNER_MISMATCH: Self

pub const DELEGATION_TOKEN_REQUEST_NOT_ALLOWED: Self

pub const DELEGATION_TOKEN_AUTHORIZATION_FAILED: Self

pub const DELEGATION_TOKEN_EXPIRED: Self

pub const INVALID_PRINCIPAL_TYPE: Self

pub const NON_EMPTY_GROUP: Self

pub const GROUP_ID_NOT_FOUND: Self

pub const FETCH_SESSION_ID_NOT_FOUND: Self

pub const INVALID_FETCH_SESSION_EPOCH: Self

pub const LISTENER_NOT_FOUND: Self

pub const TOPIC_DELETION_DISABLED: Self

pub const FENCED_LEADER_EPOCH: Self

pub const UNKNOWN_LEADER_EPOCH: Self

pub const UNSUPPORTED_COMPRESSION_TYPE: Self

pub const STALE_BROKER_EPOCH: Self

pub const OFFSET_NOT_AVAILABLE: Self

pub const MEMBER_ID_REQUIRED: Self

pub const PREFERRED_LEADER_NOT_AVAILABLE: Self

pub const GROUP_MAX_SIZE_REACHED: Self

pub const FENCED_INSTANCE_ID: Self

pub const ELIGIBLE_LEADERS_NOT_AVAILABLE: Self

pub const ELECTION_NOT_NEEDED: Self

pub const NO_REASSIGNMENT_IN_PROGRESS: Self

pub const GROUP_SUBSCRIBED_TO_TOPIC: Self

pub const INVALID_RECORD: Self

pub const UNSTABLE_OFFSET_COMMIT: Self

pub const THROTTLING_QUOTA_EXCEEDED: Self

pub const PRODUCER_FENCED: Self

pub const RESOURCE_NOT_FOUND: Self

pub const DUPLICATE_RESOURCE: Self

pub const UNACCEPTABLE_CREDENTIAL: Self

pub const INCONSISTENT_VOTER_SET: Self

pub const INVALID_UPDATE_VERSION: Self

pub const FEATURE_UPDATE_FAILED: Self

pub const PRINCIPAL_DESERIALIZATION_FAILURE: Self

pub const SNAPSHOT_NOT_FOUND: Self

pub const POSITION_OUT_OF_RANGE: Self

pub const UNKNOWN_TOPIC_ID: Self

pub const DUPLICATE_BROKER_REGISTRATION: Self

pub const BROKER_ID_NOT_REGISTERED: Self

pub const INCONSISTENT_TOPIC_ID: Self

pub const INCONSISTENT_CLUSTER_ID: Self

pub const TRANSACTIONAL_ID_NOT_FOUND: Self

pub const FETCH_SESSION_TOPIC_ID_ERROR: Self

pub const INELIGIBLE_REPLICA: Self

pub const NEW_LEADER_ELECTED: Self

pub const OFFSET_MOVED_TO_TIERED_STORAGE: Self

pub const FENCED_MEMBER_EPOCH: Self

pub const UNRELEASED_INSTANCE_ID: Self

pub const UNSUPPORTED_ASSIGNOR: Self

pub const STALE_MEMBER_EPOCH: Self

pub const MISMATCHED_ENDPOINT_TYPE: Self

pub const UNSUPPORTED_ENDPOINT_TYPE: Self

pub const UNKNOWN_CONTROLLER_ID: Self

pub const UNKNOWN_SUBSCRIPTION_ID: Self

pub const TELEMETRY_TOO_LARGE: Self

pub const INVALID_REGISTRATION: Self

Trait Implementations

impl Clone for ErrorCode

fn clone(&self) -> ErrorCode

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for ErrorCode

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

Formats the value using the given formatter.