Struct kafka_api::schemata::error::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.