Enum rdkafka::types::RDKafkaRespErr

#[repr(i32)]
pub enum RDKafkaRespErr {
    RD_KAFKA_RESP_ERR__BEGIN,
    RD_KAFKA_RESP_ERR__BAD_MSG,
    RD_KAFKA_RESP_ERR__BAD_COMPRESSION,
    RD_KAFKA_RESP_ERR__DESTROY,
    RD_KAFKA_RESP_ERR__FAIL,
    RD_KAFKA_RESP_ERR__TRANSPORT,
    RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE,
    RD_KAFKA_RESP_ERR__RESOLVE,
    RD_KAFKA_RESP_ERR__MSG_TIMED_OUT,
    RD_KAFKA_RESP_ERR__PARTITION_EOF,
    RD_KAFKA_RESP_ERR__UNKNOWN_PARTITION,
    RD_KAFKA_RESP_ERR__FS,
    RD_KAFKA_RESP_ERR__UNKNOWN_TOPIC,
    RD_KAFKA_RESP_ERR__ALL_BROKERS_DOWN,
    RD_KAFKA_RESP_ERR__INVALID_ARG,
    RD_KAFKA_RESP_ERR__TIMED_OUT,
    RD_KAFKA_RESP_ERR__QUEUE_FULL,
    RD_KAFKA_RESP_ERR__ISR_INSUFF,
    RD_KAFKA_RESP_ERR__NODE_UPDATE,
    RD_KAFKA_RESP_ERR__SSL,
    RD_KAFKA_RESP_ERR__WAIT_COORD,
    RD_KAFKA_RESP_ERR__UNKNOWN_GROUP,
    RD_KAFKA_RESP_ERR__IN_PROGRESS,
    RD_KAFKA_RESP_ERR__PREV_IN_PROGRESS,
    RD_KAFKA_RESP_ERR__EXISTING_SUBSCRIPTION,
    RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS,
    RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS,
    RD_KAFKA_RESP_ERR__CONFLICT,
    RD_KAFKA_RESP_ERR__STATE,
    RD_KAFKA_RESP_ERR__UNKNOWN_PROTOCOL,
    RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED,
    RD_KAFKA_RESP_ERR__AUTHENTICATION,
    RD_KAFKA_RESP_ERR__NO_OFFSET,
    RD_KAFKA_RESP_ERR__OUTDATED,
    RD_KAFKA_RESP_ERR__TIMED_OUT_QUEUE,
    RD_KAFKA_RESP_ERR__UNSUPPORTED_FEATURE,
    RD_KAFKA_RESP_ERR__WAIT_CACHE,
    RD_KAFKA_RESP_ERR__INTR,
    RD_KAFKA_RESP_ERR__KEY_SERIALIZATION,
    RD_KAFKA_RESP_ERR__VALUE_SERIALIZATION,
    RD_KAFKA_RESP_ERR__KEY_DESERIALIZATION,
    RD_KAFKA_RESP_ERR__VALUE_DESERIALIZATION,
    RD_KAFKA_RESP_ERR__PARTIAL,
    RD_KAFKA_RESP_ERR__READ_ONLY,
    RD_KAFKA_RESP_ERR__NOENT,
    RD_KAFKA_RESP_ERR__UNDERFLOW,
    RD_KAFKA_RESP_ERR__END,
    RD_KAFKA_RESP_ERR_UNKNOWN,
    RD_KAFKA_RESP_ERR_NO_ERROR,
    RD_KAFKA_RESP_ERR_OFFSET_OUT_OF_RANGE,
    RD_KAFKA_RESP_ERR_INVALID_MSG,
    RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_OR_PART,
    RD_KAFKA_RESP_ERR_INVALID_MSG_SIZE,
    RD_KAFKA_RESP_ERR_LEADER_NOT_AVAILABLE,
    RD_KAFKA_RESP_ERR_NOT_LEADER_FOR_PARTITION,
    RD_KAFKA_RESP_ERR_REQUEST_TIMED_OUT,
    RD_KAFKA_RESP_ERR_BROKER_NOT_AVAILABLE,
    RD_KAFKA_RESP_ERR_REPLICA_NOT_AVAILABLE,
    RD_KAFKA_RESP_ERR_MSG_SIZE_TOO_LARGE,
    RD_KAFKA_RESP_ERR_STALE_CTRL_EPOCH,
    RD_KAFKA_RESP_ERR_OFFSET_METADATA_TOO_LARGE,
    RD_KAFKA_RESP_ERR_NETWORK_EXCEPTION,
    RD_KAFKA_RESP_ERR_GROUP_LOAD_IN_PROGRESS,
    RD_KAFKA_RESP_ERR_GROUP_COORDINATOR_NOT_AVAILABLE,
    RD_KAFKA_RESP_ERR_NOT_COORDINATOR_FOR_GROUP,
    RD_KAFKA_RESP_ERR_TOPIC_EXCEPTION,
    RD_KAFKA_RESP_ERR_RECORD_LIST_TOO_LARGE,
    RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS,
    RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND,
    RD_KAFKA_RESP_ERR_INVALID_REQUIRED_ACKS,
    RD_KAFKA_RESP_ERR_ILLEGAL_GENERATION,
    RD_KAFKA_RESP_ERR_INCONSISTENT_GROUP_PROTOCOL,
    RD_KAFKA_RESP_ERR_INVALID_GROUP_ID,
    RD_KAFKA_RESP_ERR_UNKNOWN_MEMBER_ID,
    RD_KAFKA_RESP_ERR_INVALID_SESSION_TIMEOUT,
    RD_KAFKA_RESP_ERR_REBALANCE_IN_PROGRESS,
    RD_KAFKA_RESP_ERR_INVALID_COMMIT_OFFSET_SIZE,
    RD_KAFKA_RESP_ERR_TOPIC_AUTHORIZATION_FAILED,
    RD_KAFKA_RESP_ERR_GROUP_AUTHORIZATION_FAILED,
    RD_KAFKA_RESP_ERR_CLUSTER_AUTHORIZATION_FAILED,
    RD_KAFKA_RESP_ERR_INVALID_TIMESTAMP,
    RD_KAFKA_RESP_ERR_UNSUPPORTED_SASL_MECHANISM,
    RD_KAFKA_RESP_ERR_ILLEGAL_SASL_STATE,
    RD_KAFKA_RESP_ERR_UNSUPPORTED_VERSION,
    RD_KAFKA_RESP_ERR_TOPIC_ALREADY_EXISTS,
    RD_KAFKA_RESP_ERR_INVALID_PARTITIONS,
    RD_KAFKA_RESP_ERR_INVALID_REPLICATION_FACTOR,
    RD_KAFKA_RESP_ERR_INVALID_REPLICA_ASSIGNMENT,
    RD_KAFKA_RESP_ERR_INVALID_CONFIG,
    RD_KAFKA_RESP_ERR_NOT_CONTROLLER,
    RD_KAFKA_RESP_ERR_INVALID_REQUEST,
    RD_KAFKA_RESP_ERR_UNSUPPORTED_FOR_MESSAGE_FORMAT,
    RD_KAFKA_RESP_ERR_POLICY_VIOLATION,
    RD_KAFKA_RESP_ERR_OUT_OF_ORDER_SEQUENCE_NUMBER,
    RD_KAFKA_RESP_ERR_DUPLICATE_SEQUENCE_NUMBER,
    RD_KAFKA_RESP_ERR_INVALID_PRODUCER_EPOCH,
    RD_KAFKA_RESP_ERR_INVALID_TXN_STATE,
    RD_KAFKA_RESP_ERR_INVALID_PRODUCER_ID_MAPPING,
    RD_KAFKA_RESP_ERR_INVALID_TRANSACTION_TIMEOUT,
    RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS,
    RD_KAFKA_RESP_ERR_TRANSACTION_COORDINATOR_FENCED,
    RD_KAFKA_RESP_ERR_TRANSACTIONAL_ID_AUTHORIZATION_FAILED,
    RD_KAFKA_RESP_ERR_SECURITY_DISABLED,
    RD_KAFKA_RESP_ERR_OPERATION_NOT_ATTEMPTED,
    RD_KAFKA_RESP_ERR_END_ALL,
}

Variants

RD_KAFKA_RESP_ERR__BEGINRD_KAFKA_RESP_ERR__BAD_MSGRD_KAFKA_RESP_ERR__BAD_COMPRESSIONRD_KAFKA_RESP_ERR__DESTROYRD_KAFKA_RESP_ERR__FAILRD_KAFKA_RESP_ERR__TRANSPORTRD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCERD_KAFKA_RESP_ERR__RESOLVERD_KAFKA_RESP_ERR__MSG_TIMED_OUTRD_KAFKA_RESP_ERR__PARTITION_EOFRD_KAFKA_RESP_ERR__UNKNOWN_PARTITIONRD_KAFKA_RESP_ERR__FSRD_KAFKA_RESP_ERR__UNKNOWN_TOPICRD_KAFKA_RESP_ERR__ALL_BROKERS_DOWNRD_KAFKA_RESP_ERR__INVALID_ARGRD_KAFKA_RESP_ERR__TIMED_OUTRD_KAFKA_RESP_ERR__QUEUE_FULLRD_KAFKA_RESP_ERR__ISR_INSUFFRD_KAFKA_RESP_ERR__NODE_UPDATERD_KAFKA_RESP_ERR__SSLRD_KAFKA_RESP_ERR__WAIT_COORDRD_KAFKA_RESP_ERR__UNKNOWN_GROUPRD_KAFKA_RESP_ERR__IN_PROGRESSRD_KAFKA_RESP_ERR__PREV_IN_PROGRESSRD_KAFKA_RESP_ERR__EXISTING_SUBSCRIPTIONRD_KAFKA_RESP_ERR__ASSIGN_PARTITIONSRD_KAFKA_RESP_ERR__REVOKE_PARTITIONSRD_KAFKA_RESP_ERR__CONFLICTRD_KAFKA_RESP_ERR__STATERD_KAFKA_RESP_ERR__UNKNOWN_PROTOCOLRD_KAFKA_RESP_ERR__NOT_IMPLEMENTEDRD_KAFKA_RESP_ERR__AUTHENTICATIONRD_KAFKA_RESP_ERR__NO_OFFSETRD_KAFKA_RESP_ERR__OUTDATEDRD_KAFKA_RESP_ERR__TIMED_OUT_QUEUERD_KAFKA_RESP_ERR__UNSUPPORTED_FEATURERD_KAFKA_RESP_ERR__WAIT_CACHERD_KAFKA_RESP_ERR__INTRRD_KAFKA_RESP_ERR__KEY_SERIALIZATIONRD_KAFKA_RESP_ERR__VALUE_SERIALIZATIONRD_KAFKA_RESP_ERR__KEY_DESERIALIZATIONRD_KAFKA_RESP_ERR__VALUE_DESERIALIZATIONRD_KAFKA_RESP_ERR__PARTIALRD_KAFKA_RESP_ERR__READ_ONLYRD_KAFKA_RESP_ERR__NOENTRD_KAFKA_RESP_ERR__UNDERFLOWRD_KAFKA_RESP_ERR__ENDRD_KAFKA_RESP_ERR_UNKNOWNRD_KAFKA_RESP_ERR_NO_ERRORRD_KAFKA_RESP_ERR_OFFSET_OUT_OF_RANGERD_KAFKA_RESP_ERR_INVALID_MSGRD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_OR_PARTRD_KAFKA_RESP_ERR_INVALID_MSG_SIZERD_KAFKA_RESP_ERR_LEADER_NOT_AVAILABLERD_KAFKA_RESP_ERR_NOT_LEADER_FOR_PARTITIONRD_KAFKA_RESP_ERR_REQUEST_TIMED_OUTRD_KAFKA_RESP_ERR_BROKER_NOT_AVAILABLERD_KAFKA_RESP_ERR_REPLICA_NOT_AVAILABLERD_KAFKA_RESP_ERR_MSG_SIZE_TOO_LARGERD_KAFKA_RESP_ERR_STALE_CTRL_EPOCHRD_KAFKA_RESP_ERR_OFFSET_METADATA_TOO_LARGERD_KAFKA_RESP_ERR_NETWORK_EXCEPTIONRD_KAFKA_RESP_ERR_GROUP_LOAD_IN_PROGRESSRD_KAFKA_RESP_ERR_GROUP_COORDINATOR_NOT_AVAILABLERD_KAFKA_RESP_ERR_NOT_COORDINATOR_FOR_GROUPRD_KAFKA_RESP_ERR_TOPIC_EXCEPTIONRD_KAFKA_RESP_ERR_RECORD_LIST_TOO_LARGERD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICASRD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS_AFTER_APPENDRD_KAFKA_RESP_ERR_INVALID_REQUIRED_ACKSRD_KAFKA_RESP_ERR_ILLEGAL_GENERATIONRD_KAFKA_RESP_ERR_INCONSISTENT_GROUP_PROTOCOLRD_KAFKA_RESP_ERR_INVALID_GROUP_IDRD_KAFKA_RESP_ERR_UNKNOWN_MEMBER_IDRD_KAFKA_RESP_ERR_INVALID_SESSION_TIMEOUTRD_KAFKA_RESP_ERR_REBALANCE_IN_PROGRESSRD_KAFKA_RESP_ERR_INVALID_COMMIT_OFFSET_SIZERD_KAFKA_RESP_ERR_TOPIC_AUTHORIZATION_FAILEDRD_KAFKA_RESP_ERR_GROUP_AUTHORIZATION_FAILEDRD_KAFKA_RESP_ERR_CLUSTER_AUTHORIZATION_FAILEDRD_KAFKA_RESP_ERR_INVALID_TIMESTAMPRD_KAFKA_RESP_ERR_UNSUPPORTED_SASL_MECHANISMRD_KAFKA_RESP_ERR_ILLEGAL_SASL_STATERD_KAFKA_RESP_ERR_UNSUPPORTED_VERSIONRD_KAFKA_RESP_ERR_TOPIC_ALREADY_EXISTSRD_KAFKA_RESP_ERR_INVALID_PARTITIONSRD_KAFKA_RESP_ERR_INVALID_REPLICATION_FACTORRD_KAFKA_RESP_ERR_INVALID_REPLICA_ASSIGNMENTRD_KAFKA_RESP_ERR_INVALID_CONFIGRD_KAFKA_RESP_ERR_NOT_CONTROLLERRD_KAFKA_RESP_ERR_INVALID_REQUESTRD_KAFKA_RESP_ERR_UNSUPPORTED_FOR_MESSAGE_FORMATRD_KAFKA_RESP_ERR_POLICY_VIOLATIONRD_KAFKA_RESP_ERR_OUT_OF_ORDER_SEQUENCE_NUMBERRD_KAFKA_RESP_ERR_DUPLICATE_SEQUENCE_NUMBERRD_KAFKA_RESP_ERR_INVALID_PRODUCER_EPOCHRD_KAFKA_RESP_ERR_INVALID_TXN_STATERD_KAFKA_RESP_ERR_INVALID_PRODUCER_ID_MAPPINGRD_KAFKA_RESP_ERR_INVALID_TRANSACTION_TIMEOUTRD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONSRD_KAFKA_RESP_ERR_TRANSACTION_COORDINATOR_FENCEDRD_KAFKA_RESP_ERR_TRANSACTIONAL_ID_AUTHORIZATION_FAILEDRD_KAFKA_RESP_ERR_SECURITY_DISABLEDRD_KAFKA_RESP_ERR_OPERATION_NOT_ATTEMPTEDRD_KAFKA_RESP_ERR_END_ALL

Trait Implementations

impl Hash for rd_kafka_resp_err_t

fn hash<__H>(&self, state: &mut __H) where     __H: Hasher,

Feeds this value into the given [Hasher].

fn hash_slice<H>(data: &[Self], state: &mut H) where     H: Hasher,

Feeds a slice of this type into the given [Hasher].

impl Clone for rd_kafka_resp_err_t

fn clone(&self) -> rd_kafka_resp_err_t

Returns a copy of the value.

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

Performs copy-assignment from source.

impl Debug for rd_kafka_resp_err_t

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

Formats the value using the given formatter.

impl Copy for rd_kafka_resp_err_t

impl Eq for rd_kafka_resp_err_t

impl PartialEq<rd_kafka_resp_err_t> for rd_kafka_resp_err_t

fn eq(&self, other: &rd_kafka_resp_err_t) -> bool

This method tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

This method tests for !=.

impl From<rd_kafka_resp_err_t> for RDKafkaError

fn from(err: rd_kafka_resp_err_t) -> RDKafkaError

Performs the conversion.

impl IsError for RDKafkaRespErr

fn is_error(self) -> bool

Return true if the value represents an error.