Struct kafka_api::error::Error

pub struct Error { /* private fields */ }

Implementations

impl Error

pub const UNKNOWN_SERVER_ERROR: Error = _

pub const NONE: Error = _

pub const OFFSET_OUT_OF_RANGE: Error = _

pub const CORRUPT_MESSAGE: Error = _

pub const UNKNOWN_TOPIC_OR_PARTITION: Error = _

pub const INVALID_FETCH_SIZE: Error = _

pub const LEADER_NOT_AVAILABLE: Error = _

pub const NOT_LEADER_OR_FOLLOWER: Error = _

pub const REQUEST_TIMED_OUT: Error = _

pub const BROKER_NOT_AVAILABLE: Error = _

pub const REPLICA_NOT_AVAILABLE: Error = _

pub const MESSAGE_TOO_LARGE: Error = _

pub const STALE_CONTROLLER_EPOCH: Error = _

pub const OFFSET_METADATA_TOO_LARGE: Error = _

pub const NETWORK_EXCEPTION: Error = _

pub const COORDINATOR_LOAD_IN_PROGRESS: Error = _

pub const COORDINATOR_NOT_AVAILABLE: Error = _

pub const NOT_COORDINATOR: Error = _

pub const INVALID_TOPIC_EXCEPTION: Error = _

pub const RECORD_LIST_TOO_LARGE: Error = _

pub const NOT_ENOUGH_REPLICAS: Error = _

pub const NOT_ENOUGH_REPLICAS_AFTER_APPEND: Error = _

pub const INVALID_REQUIRED_ACKS: Error = _

pub const ILLEGAL_GENERATION: Error = _

pub const INCONSISTENT_GROUP_PROTOCOL: Error = _

pub const INVALID_GROUP_ID: Error = _

pub const UNKNOWN_MEMBER_ID: Error = _

pub const INVALID_SESSION_TIMEOUT: Error = _

pub const REBALANCE_IN_PROGRESS: Error = _

pub const INVALID_COMMIT_OFFSET_SIZE: Error = _

pub const TOPIC_AUTHORIZATION_FAILED: Error = _

pub const GROUP_AUTHORIZATION_FAILED: Error = _

pub const CLUSTER_AUTHORIZATION_FAILED: Error = _

pub const INVALID_TIMESTAMP: Error = _

pub const UNSUPPORTED_SASL_MECHANISM: Error = _

pub const ILLEGAL_SASL_STATE: Error = _

pub const UNSUPPORTED_VERSION: Error = _

pub const TOPIC_ALREADY_EXISTS: Error = _

pub const INVALID_PARTITIONS: Error = _

pub const INVALID_REPLICATION_FACTOR: Error = _

pub const INVALID_REPLICA_ASSIGNMENT: Error = _

pub const INVALID_CONFIG: Error = _

pub const NOT_CONTROLLER: Error = _

pub const INVALID_REQUEST: Error = _

pub const UNSUPPORTED_FOR_MESSAGE_FORMAT: Error = _

pub const POLICY_VIOLATION: Error = _

pub const OUT_OF_ORDER_SEQUENCE_NUMBER: Error = _

pub const DUPLICATE_SEQUENCE_NUMBER: Error = _

pub const INVALID_PRODUCER_EPOCH: Error = _

pub const INVALID_TXN_STATE: Error = _

pub const INVALID_PRODUCER_ID_MAPPING: Error = _

pub const INVALID_TRANSACTION_TIMEOUT: Error = _

pub const CONCURRENT_TRANSACTIONS: Error = _

pub const TRANSACTION_COORDINATOR_FENCED: Error = _

pub const TRANSACTIONAL_ID_AUTHORIZATION_FAILED: Error = _

pub const SECURITY_DISABLED: Error = _

pub const OPERATION_NOT_ATTEMPTED: Error = _

pub const KAFKA_STORAGE_ERROR: Error = _

pub const LOG_DIR_NOT_FOUND: Error = _

pub const SASL_AUTHENTICATION_FAILED: Error = _

pub const UNKNOWN_PRODUCER_ID: Error = _

pub const REASSIGNMENT_IN_PROGRESS: Error = _

pub const DELEGATION_TOKEN_AUTH_DISABLED: Error = _

pub const DELEGATION_TOKEN_NOT_FOUND: Error = _

pub const DELEGATION_TOKEN_OWNER_MISMATCH: Error = _

pub const DELEGATION_TOKEN_REQUEST_NOT_ALLOWED: Error = _

pub const DELEGATION_TOKEN_AUTHORIZATION_FAILED: Error = _

pub const DELEGATION_TOKEN_EXPIRED: Error = _

pub const INVALID_PRINCIPAL_TYPE: Error = _

pub const NON_EMPTY_GROUP: Error = _

pub const GROUP_ID_NOT_FOUND: Error = _

pub const FETCH_SESSION_ID_NOT_FOUND: Error = _

pub const INVALID_FETCH_SESSION_EPOCH: Error = _

pub const LISTENER_NOT_FOUND: Error = _

pub const TOPIC_DELETION_DISABLED: Error = _

pub const FENCED_LEADER_EPOCH: Error = _

pub const UNKNOWN_LEADER_EPOCH: Error = _

pub const UNSUPPORTED_COMPRESSION_TYPE: Error = _

pub const STALE_BROKER_EPOCH: Error = _

pub const OFFSET_NOT_AVAILABLE: Error = _

pub const MEMBER_ID_REQUIRED: Error = _

pub const PREFERRED_LEADER_NOT_AVAILABLE: Error = _

pub const GROUP_MAX_SIZE_REACHED: Error = _

pub const FENCED_INSTANCE_ID: Error = _

pub const ELIGIBLE_LEADERS_NOT_AVAILABLE: Error = _

pub const ELECTION_NOT_NEEDED: Error = _

pub const NO_REASSIGNMENT_IN_PROGRESS: Error = _

pub const GROUP_SUBSCRIBED_TO_TOPIC: Error = _

pub const INVALID_RECORD: Error = _

pub const UNSTABLE_OFFSET_COMMIT: Error = _

pub const THROTTLING_QUOTA_EXCEEDED: Error = _

pub const PRODUCER_FENCED: Error = _

pub const RESOURCE_NOT_FOUND: Error = _

pub const DUPLICATE_RESOURCE: Error = _

pub const UNACCEPTABLE_CREDENTIAL: Error = _

pub const INCONSISTENT_VOTER_SET: Error = _

pub const INVALID_UPDATE_VERSION: Error = _

pub const FEATURE_UPDATE_FAILED: Error = _

pub const PRINCIPAL_DESERIALIZATION_FAILURE: Error = _

pub const SNAPSHOT_NOT_FOUND: Error = _

pub const POSITION_OUT_OF_RANGE: Error = _

pub const UNKNOWN_TOPIC_ID: Error = _

pub const DUPLICATE_BROKER_REGISTRATION: Error = _

pub const BROKER_ID_NOT_REGISTERED: Error = _

pub const INCONSISTENT_TOPIC_ID: Error = _

pub const INCONSISTENT_CLUSTER_ID: Error = _

pub const TRANSACTIONAL_ID_NOT_FOUND: Error = _

pub const FETCH_SESSION_TOPIC_ID_ERROR: Error = _

pub const INELIGIBLE_REPLICA: Error = _

pub const NEW_LEADER_ELECTED: Error = _

pub const OFFSET_MOVED_TO_TIERED_STORAGE: Error = _

pub const FENCED_MEMBER_EPOCH: Error = _

pub const UNRELEASED_INSTANCE_ID: Error = _

pub const UNSUPPORTED_ASSIGNOR: Error = _

pub fn code(&self) -> i16

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

pub fn retryable(&self) -> bool

Trait Implementations

impl Clone for Error

fn clone(&self) -> Error

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for Error

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

Formats the value using the given formatter.