#[repr(i32)]pub enum rd_kafka_resp_err_t {
Show 173 variants
RD_KAFKA_RESP_ERR__BEGIN = -200,
RD_KAFKA_RESP_ERR__BAD_MSG = -199,
RD_KAFKA_RESP_ERR__BAD_COMPRESSION = -198,
RD_KAFKA_RESP_ERR__DESTROY = -197,
RD_KAFKA_RESP_ERR__FAIL = -196,
RD_KAFKA_RESP_ERR__TRANSPORT = -195,
RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE = -194,
RD_KAFKA_RESP_ERR__RESOLVE = -193,
RD_KAFKA_RESP_ERR__MSG_TIMED_OUT = -192,
RD_KAFKA_RESP_ERR__PARTITION_EOF = -191,
RD_KAFKA_RESP_ERR__UNKNOWN_PARTITION = -190,
RD_KAFKA_RESP_ERR__FS = -189,
RD_KAFKA_RESP_ERR__UNKNOWN_TOPIC = -188,
RD_KAFKA_RESP_ERR__ALL_BROKERS_DOWN = -187,
RD_KAFKA_RESP_ERR__INVALID_ARG = -186,
RD_KAFKA_RESP_ERR__TIMED_OUT = -185,
RD_KAFKA_RESP_ERR__QUEUE_FULL = -184,
RD_KAFKA_RESP_ERR__ISR_INSUFF = -183,
RD_KAFKA_RESP_ERR__NODE_UPDATE = -182,
RD_KAFKA_RESP_ERR__SSL = -181,
RD_KAFKA_RESP_ERR__WAIT_COORD = -180,
RD_KAFKA_RESP_ERR__UNKNOWN_GROUP = -179,
RD_KAFKA_RESP_ERR__IN_PROGRESS = -178,
RD_KAFKA_RESP_ERR__PREV_IN_PROGRESS = -177,
RD_KAFKA_RESP_ERR__EXISTING_SUBSCRIPTION = -176,
RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS = -175,
RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS = -174,
RD_KAFKA_RESP_ERR__CONFLICT = -173,
RD_KAFKA_RESP_ERR__STATE = -172,
RD_KAFKA_RESP_ERR__UNKNOWN_PROTOCOL = -171,
RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED = -170,
RD_KAFKA_RESP_ERR__AUTHENTICATION = -169,
RD_KAFKA_RESP_ERR__NO_OFFSET = -168,
RD_KAFKA_RESP_ERR__OUTDATED = -167,
RD_KAFKA_RESP_ERR__TIMED_OUT_QUEUE = -166,
RD_KAFKA_RESP_ERR__UNSUPPORTED_FEATURE = -165,
RD_KAFKA_RESP_ERR__WAIT_CACHE = -164,
RD_KAFKA_RESP_ERR__INTR = -163,
RD_KAFKA_RESP_ERR__KEY_SERIALIZATION = -162,
RD_KAFKA_RESP_ERR__VALUE_SERIALIZATION = -161,
RD_KAFKA_RESP_ERR__KEY_DESERIALIZATION = -160,
RD_KAFKA_RESP_ERR__VALUE_DESERIALIZATION = -159,
RD_KAFKA_RESP_ERR__PARTIAL = -158,
RD_KAFKA_RESP_ERR__READ_ONLY = -157,
RD_KAFKA_RESP_ERR__NOENT = -156,
RD_KAFKA_RESP_ERR__UNDERFLOW = -155,
RD_KAFKA_RESP_ERR__INVALID_TYPE = -154,
RD_KAFKA_RESP_ERR__RETRY = -153,
RD_KAFKA_RESP_ERR__PURGE_QUEUE = -152,
RD_KAFKA_RESP_ERR__PURGE_INFLIGHT = -151,
RD_KAFKA_RESP_ERR__FATAL = -150,
RD_KAFKA_RESP_ERR__INCONSISTENT = -149,
RD_KAFKA_RESP_ERR__GAPLESS_GUARANTEE = -148,
RD_KAFKA_RESP_ERR__MAX_POLL_EXCEEDED = -147,
RD_KAFKA_RESP_ERR__UNKNOWN_BROKER = -146,
RD_KAFKA_RESP_ERR__NOT_CONFIGURED = -145,
RD_KAFKA_RESP_ERR__FENCED = -144,
RD_KAFKA_RESP_ERR__APPLICATION = -143,
RD_KAFKA_RESP_ERR__ASSIGNMENT_LOST = -142,
RD_KAFKA_RESP_ERR__NOOP = -141,
RD_KAFKA_RESP_ERR__AUTO_OFFSET_RESET = -140,
RD_KAFKA_RESP_ERR__LOG_TRUNCATION = -139,
RD_KAFKA_RESP_ERR__INVALID_DIFFERENT_RECORD = -138,
RD_KAFKA_RESP_ERR__DESTROY_BROKER = -137,
RD_KAFKA_RESP_ERR__END = -100,
RD_KAFKA_RESP_ERR_UNKNOWN = -1,
RD_KAFKA_RESP_ERR_NO_ERROR = 0,
RD_KAFKA_RESP_ERR_OFFSET_OUT_OF_RANGE = 1,
RD_KAFKA_RESP_ERR_INVALID_MSG = 2,
RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_OR_PART = 3,
RD_KAFKA_RESP_ERR_INVALID_MSG_SIZE = 4,
RD_KAFKA_RESP_ERR_LEADER_NOT_AVAILABLE = 5,
RD_KAFKA_RESP_ERR_NOT_LEADER_FOR_PARTITION = 6,
RD_KAFKA_RESP_ERR_REQUEST_TIMED_OUT = 7,
RD_KAFKA_RESP_ERR_BROKER_NOT_AVAILABLE = 8,
RD_KAFKA_RESP_ERR_REPLICA_NOT_AVAILABLE = 9,
RD_KAFKA_RESP_ERR_MSG_SIZE_TOO_LARGE = 10,
RD_KAFKA_RESP_ERR_STALE_CTRL_EPOCH = 11,
RD_KAFKA_RESP_ERR_OFFSET_METADATA_TOO_LARGE = 12,
RD_KAFKA_RESP_ERR_NETWORK_EXCEPTION = 13,
RD_KAFKA_RESP_ERR_COORDINATOR_LOAD_IN_PROGRESS = 14,
RD_KAFKA_RESP_ERR_COORDINATOR_NOT_AVAILABLE = 15,
RD_KAFKA_RESP_ERR_NOT_COORDINATOR = 16,
RD_KAFKA_RESP_ERR_TOPIC_EXCEPTION = 17,
RD_KAFKA_RESP_ERR_RECORD_LIST_TOO_LARGE = 18,
RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS = 19,
RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND = 20,
RD_KAFKA_RESP_ERR_INVALID_REQUIRED_ACKS = 21,
RD_KAFKA_RESP_ERR_ILLEGAL_GENERATION = 22,
RD_KAFKA_RESP_ERR_INCONSISTENT_GROUP_PROTOCOL = 23,
RD_KAFKA_RESP_ERR_INVALID_GROUP_ID = 24,
RD_KAFKA_RESP_ERR_UNKNOWN_MEMBER_ID = 25,
RD_KAFKA_RESP_ERR_INVALID_SESSION_TIMEOUT = 26,
RD_KAFKA_RESP_ERR_REBALANCE_IN_PROGRESS = 27,
RD_KAFKA_RESP_ERR_INVALID_COMMIT_OFFSET_SIZE = 28,
RD_KAFKA_RESP_ERR_TOPIC_AUTHORIZATION_FAILED = 29,
RD_KAFKA_RESP_ERR_GROUP_AUTHORIZATION_FAILED = 30,
RD_KAFKA_RESP_ERR_CLUSTER_AUTHORIZATION_FAILED = 31,
RD_KAFKA_RESP_ERR_INVALID_TIMESTAMP = 32,
RD_KAFKA_RESP_ERR_UNSUPPORTED_SASL_MECHANISM = 33,
RD_KAFKA_RESP_ERR_ILLEGAL_SASL_STATE = 34,
RD_KAFKA_RESP_ERR_UNSUPPORTED_VERSION = 35,
RD_KAFKA_RESP_ERR_TOPIC_ALREADY_EXISTS = 36,
RD_KAFKA_RESP_ERR_INVALID_PARTITIONS = 37,
RD_KAFKA_RESP_ERR_INVALID_REPLICATION_FACTOR = 38,
RD_KAFKA_RESP_ERR_INVALID_REPLICA_ASSIGNMENT = 39,
RD_KAFKA_RESP_ERR_INVALID_CONFIG = 40,
RD_KAFKA_RESP_ERR_NOT_CONTROLLER = 41,
RD_KAFKA_RESP_ERR_INVALID_REQUEST = 42,
RD_KAFKA_RESP_ERR_UNSUPPORTED_FOR_MESSAGE_FORMAT = 43,
RD_KAFKA_RESP_ERR_POLICY_VIOLATION = 44,
RD_KAFKA_RESP_ERR_OUT_OF_ORDER_SEQUENCE_NUMBER = 45,
RD_KAFKA_RESP_ERR_DUPLICATE_SEQUENCE_NUMBER = 46,
RD_KAFKA_RESP_ERR_INVALID_PRODUCER_EPOCH = 47,
RD_KAFKA_RESP_ERR_INVALID_TXN_STATE = 48,
RD_KAFKA_RESP_ERR_INVALID_PRODUCER_ID_MAPPING = 49,
RD_KAFKA_RESP_ERR_INVALID_TRANSACTION_TIMEOUT = 50,
RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS = 51,
RD_KAFKA_RESP_ERR_TRANSACTION_COORDINATOR_FENCED = 52,
RD_KAFKA_RESP_ERR_TRANSACTIONAL_ID_AUTHORIZATION_FAILED = 53,
RD_KAFKA_RESP_ERR_SECURITY_DISABLED = 54,
RD_KAFKA_RESP_ERR_OPERATION_NOT_ATTEMPTED = 55,
RD_KAFKA_RESP_ERR_KAFKA_STORAGE_ERROR = 56,
RD_KAFKA_RESP_ERR_LOG_DIR_NOT_FOUND = 57,
RD_KAFKA_RESP_ERR_SASL_AUTHENTICATION_FAILED = 58,
RD_KAFKA_RESP_ERR_UNKNOWN_PRODUCER_ID = 59,
RD_KAFKA_RESP_ERR_REASSIGNMENT_IN_PROGRESS = 60,
RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_AUTH_DISABLED = 61,
RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_NOT_FOUND = 62,
RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_OWNER_MISMATCH = 63,
RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_REQUEST_NOT_ALLOWED = 64,
RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_AUTHORIZATION_FAILED = 65,
RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_EXPIRED = 66,
RD_KAFKA_RESP_ERR_INVALID_PRINCIPAL_TYPE = 67,
RD_KAFKA_RESP_ERR_NON_EMPTY_GROUP = 68,
RD_KAFKA_RESP_ERR_GROUP_ID_NOT_FOUND = 69,
RD_KAFKA_RESP_ERR_FETCH_SESSION_ID_NOT_FOUND = 70,
RD_KAFKA_RESP_ERR_INVALID_FETCH_SESSION_EPOCH = 71,
RD_KAFKA_RESP_ERR_LISTENER_NOT_FOUND = 72,
RD_KAFKA_RESP_ERR_TOPIC_DELETION_DISABLED = 73,
RD_KAFKA_RESP_ERR_FENCED_LEADER_EPOCH = 74,
RD_KAFKA_RESP_ERR_UNKNOWN_LEADER_EPOCH = 75,
RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE = 76,
RD_KAFKA_RESP_ERR_STALE_BROKER_EPOCH = 77,
RD_KAFKA_RESP_ERR_OFFSET_NOT_AVAILABLE = 78,
RD_KAFKA_RESP_ERR_MEMBER_ID_REQUIRED = 79,
RD_KAFKA_RESP_ERR_PREFERRED_LEADER_NOT_AVAILABLE = 80,
RD_KAFKA_RESP_ERR_GROUP_MAX_SIZE_REACHED = 81,
RD_KAFKA_RESP_ERR_FENCED_INSTANCE_ID = 82,
RD_KAFKA_RESP_ERR_ELIGIBLE_LEADERS_NOT_AVAILABLE = 83,
RD_KAFKA_RESP_ERR_ELECTION_NOT_NEEDED = 84,
RD_KAFKA_RESP_ERR_NO_REASSIGNMENT_IN_PROGRESS = 85,
RD_KAFKA_RESP_ERR_GROUP_SUBSCRIBED_TO_TOPIC = 86,
RD_KAFKA_RESP_ERR_INVALID_RECORD = 87,
RD_KAFKA_RESP_ERR_UNSTABLE_OFFSET_COMMIT = 88,
RD_KAFKA_RESP_ERR_THROTTLING_QUOTA_EXCEEDED = 89,
RD_KAFKA_RESP_ERR_PRODUCER_FENCED = 90,
RD_KAFKA_RESP_ERR_RESOURCE_NOT_FOUND = 91,
RD_KAFKA_RESP_ERR_DUPLICATE_RESOURCE = 92,
RD_KAFKA_RESP_ERR_UNACCEPTABLE_CREDENTIAL = 93,
RD_KAFKA_RESP_ERR_INCONSISTENT_VOTER_SET = 94,
RD_KAFKA_RESP_ERR_INVALID_UPDATE_VERSION = 95,
RD_KAFKA_RESP_ERR_FEATURE_UPDATE_FAILED = 96,
RD_KAFKA_RESP_ERR_PRINCIPAL_DESERIALIZATION_FAILURE = 97,
RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_ID = 100,
RD_KAFKA_RESP_ERR_FENCED_MEMBER_EPOCH = 110,
RD_KAFKA_RESP_ERR_UNRELEASED_INSTANCE_ID = 111,
RD_KAFKA_RESP_ERR_UNSUPPORTED_ASSIGNOR = 112,
RD_KAFKA_RESP_ERR_STALE_MEMBER_EPOCH = 113,
RD_KAFKA_RESP_ERR_UNKNOWN_SUBSCRIPTION_ID = 117,
RD_KAFKA_RESP_ERR_TELEMETRY_TOO_LARGE = 118,
RD_KAFKA_RESP_ERR_REBOOTSTRAP_REQUIRED = 129,
RD_KAFKA_RESP_ERR_END_ALL = 130,
}Expand description
@enum rd_kafka_resp_err_t Error codes.
The negative error codes delimited by two underscores
(RD_KAFKA_RESP_ERR__..) denotes errors internal to librdkafka and are displayed as "Local: <error string..>", while the error codes
delimited by a single underscore (RD_KAFKA_RESP_ERR_..) denote broker errors and are displayed as "Broker: <error string..>".
@sa Use rd_kafka_err2str() to translate an error code a human readable string
Variants§
RD_KAFKA_RESP_ERR__BEGIN = -200
Begin internal error codes
RD_KAFKA_RESP_ERR__BAD_MSG = -199
Received message is incorrect
RD_KAFKA_RESP_ERR__BAD_COMPRESSION = -198
Bad/unknown compression
RD_KAFKA_RESP_ERR__DESTROY = -197
Broker is going away, together with client instance
RD_KAFKA_RESP_ERR__FAIL = -196
Generic failure
RD_KAFKA_RESP_ERR__TRANSPORT = -195
Broker transport failure
RD_KAFKA_RESP_ERR__CRIT_SYS_RESOURCE = -194
Critical system resource
RD_KAFKA_RESP_ERR__RESOLVE = -193
Failed to resolve broker
RD_KAFKA_RESP_ERR__MSG_TIMED_OUT = -192
Produced message timed out
RD_KAFKA_RESP_ERR__PARTITION_EOF = -191
Reached the end of the topic+partition queue on
the broker. Not really an error.
This event is disabled by default,
see the enable.partition.eof configuration property.
RD_KAFKA_RESP_ERR__UNKNOWN_PARTITION = -190
Permanent: Partition does not exist in cluster.
RD_KAFKA_RESP_ERR__FS = -189
File or filesystem error
RD_KAFKA_RESP_ERR__UNKNOWN_TOPIC = -188
Permanent: Topic does not exist in cluster.
RD_KAFKA_RESP_ERR__ALL_BROKERS_DOWN = -187
All broker connections are down.
RD_KAFKA_RESP_ERR__INVALID_ARG = -186
Invalid argument, or invalid configuration
RD_KAFKA_RESP_ERR__TIMED_OUT = -185
Operation timed out
RD_KAFKA_RESP_ERR__QUEUE_FULL = -184
Queue is full
RD_KAFKA_RESP_ERR__ISR_INSUFF = -183
ISR count < required.acks
RD_KAFKA_RESP_ERR__NODE_UPDATE = -182
Broker node update
RD_KAFKA_RESP_ERR__SSL = -181
SSL error
RD_KAFKA_RESP_ERR__WAIT_COORD = -180
Waiting for coordinator to become available.
RD_KAFKA_RESP_ERR__UNKNOWN_GROUP = -179
Unknown client group
RD_KAFKA_RESP_ERR__IN_PROGRESS = -178
Operation in progress
RD_KAFKA_RESP_ERR__PREV_IN_PROGRESS = -177
Previous operation in progress, wait for it to finish.
RD_KAFKA_RESP_ERR__EXISTING_SUBSCRIPTION = -176
This operation would interfere with an existing subscription
RD_KAFKA_RESP_ERR__ASSIGN_PARTITIONS = -175
Assigned partitions (rebalance_cb)
RD_KAFKA_RESP_ERR__REVOKE_PARTITIONS = -174
Revoked partitions (rebalance_cb)
RD_KAFKA_RESP_ERR__CONFLICT = -173
Conflicting use
RD_KAFKA_RESP_ERR__STATE = -172
Wrong state
RD_KAFKA_RESP_ERR__UNKNOWN_PROTOCOL = -171
Unknown protocol
RD_KAFKA_RESP_ERR__NOT_IMPLEMENTED = -170
Not implemented
RD_KAFKA_RESP_ERR__AUTHENTICATION = -169
Authentication failure
RD_KAFKA_RESP_ERR__NO_OFFSET = -168
No stored offset
RD_KAFKA_RESP_ERR__OUTDATED = -167
Outdated
RD_KAFKA_RESP_ERR__TIMED_OUT_QUEUE = -166
Timed out in queue
RD_KAFKA_RESP_ERR__UNSUPPORTED_FEATURE = -165
Feature not supported by broker
RD_KAFKA_RESP_ERR__WAIT_CACHE = -164
Awaiting cache update
RD_KAFKA_RESP_ERR__INTR = -163
Operation interrupted (e.g., due to yield))
RD_KAFKA_RESP_ERR__KEY_SERIALIZATION = -162
Key serialization error
RD_KAFKA_RESP_ERR__VALUE_SERIALIZATION = -161
Value serialization error
RD_KAFKA_RESP_ERR__KEY_DESERIALIZATION = -160
Key deserialization error
RD_KAFKA_RESP_ERR__VALUE_DESERIALIZATION = -159
Value deserialization error
RD_KAFKA_RESP_ERR__PARTIAL = -158
Partial response
RD_KAFKA_RESP_ERR__READ_ONLY = -157
Modification attempted on read-only object
RD_KAFKA_RESP_ERR__NOENT = -156
No such entry / item not found
RD_KAFKA_RESP_ERR__UNDERFLOW = -155
Read underflow
RD_KAFKA_RESP_ERR__INVALID_TYPE = -154
Invalid type
RD_KAFKA_RESP_ERR__RETRY = -153
Retry operation
RD_KAFKA_RESP_ERR__PURGE_QUEUE = -152
Purged in queue
RD_KAFKA_RESP_ERR__PURGE_INFLIGHT = -151
Purged in flight
RD_KAFKA_RESP_ERR__FATAL = -150
Fatal error: see rd_kafka_fatal_error()
RD_KAFKA_RESP_ERR__INCONSISTENT = -149
Inconsistent state
RD_KAFKA_RESP_ERR__GAPLESS_GUARANTEE = -148
Gap-less ordering would not be guaranteed if proceeding
RD_KAFKA_RESP_ERR__MAX_POLL_EXCEEDED = -147
Maximum poll interval exceeded
RD_KAFKA_RESP_ERR__UNKNOWN_BROKER = -146
Unknown broker
RD_KAFKA_RESP_ERR__NOT_CONFIGURED = -145
Functionality not configured
RD_KAFKA_RESP_ERR__FENCED = -144
Instance has been fenced
RD_KAFKA_RESP_ERR__APPLICATION = -143
Application generated error
RD_KAFKA_RESP_ERR__ASSIGNMENT_LOST = -142
Assignment lost
RD_KAFKA_RESP_ERR__NOOP = -141
No operation performed
RD_KAFKA_RESP_ERR__AUTO_OFFSET_RESET = -140
No offset to automatically reset to
RD_KAFKA_RESP_ERR__LOG_TRUNCATION = -139
Partition log truncation detected
RD_KAFKA_RESP_ERR__INVALID_DIFFERENT_RECORD = -138
A different record in the batch was invalid and this message failed persisting.
RD_KAFKA_RESP_ERR__DESTROY_BROKER = -137
Broker is going away but client isn’t terminating
RD_KAFKA_RESP_ERR__END = -100
End internal error codes
RD_KAFKA_RESP_ERR_UNKNOWN = -1
Unknown broker error
RD_KAFKA_RESP_ERR_NO_ERROR = 0
Success
RD_KAFKA_RESP_ERR_OFFSET_OUT_OF_RANGE = 1
Offset out of range
RD_KAFKA_RESP_ERR_INVALID_MSG = 2
Invalid message
RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_OR_PART = 3
Unknown topic or partition
RD_KAFKA_RESP_ERR_INVALID_MSG_SIZE = 4
Invalid message size
RD_KAFKA_RESP_ERR_LEADER_NOT_AVAILABLE = 5
Leader not available
RD_KAFKA_RESP_ERR_NOT_LEADER_FOR_PARTITION = 6
RD_KAFKA_RESP_ERR_REQUEST_TIMED_OUT = 7
Request timed out
RD_KAFKA_RESP_ERR_BROKER_NOT_AVAILABLE = 8
Broker not available
RD_KAFKA_RESP_ERR_REPLICA_NOT_AVAILABLE = 9
Replica not available
RD_KAFKA_RESP_ERR_MSG_SIZE_TOO_LARGE = 10
Message size too large
RD_KAFKA_RESP_ERR_STALE_CTRL_EPOCH = 11
StaleControllerEpochCode
RD_KAFKA_RESP_ERR_OFFSET_METADATA_TOO_LARGE = 12
Offset metadata string too large
RD_KAFKA_RESP_ERR_NETWORK_EXCEPTION = 13
Broker disconnected before response received
RD_KAFKA_RESP_ERR_COORDINATOR_LOAD_IN_PROGRESS = 14
Coordinator load in progress
RD_KAFKA_RESP_ERR_COORDINATOR_NOT_AVAILABLE = 15
Coordinator not available
RD_KAFKA_RESP_ERR_NOT_COORDINATOR = 16
Not coordinator
RD_KAFKA_RESP_ERR_TOPIC_EXCEPTION = 17
Invalid topic
RD_KAFKA_RESP_ERR_RECORD_LIST_TOO_LARGE = 18
Message batch larger than configured server segment size
RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS = 19
Not enough in-sync replicas
RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND = 20
Message(s) written to insufficient number of in-sync replicas
RD_KAFKA_RESP_ERR_INVALID_REQUIRED_ACKS = 21
Invalid required acks value
RD_KAFKA_RESP_ERR_ILLEGAL_GENERATION = 22
Specified group generation id is not valid
RD_KAFKA_RESP_ERR_INCONSISTENT_GROUP_PROTOCOL = 23
Inconsistent group protocol
RD_KAFKA_RESP_ERR_INVALID_GROUP_ID = 24
Invalid group.id
RD_KAFKA_RESP_ERR_UNKNOWN_MEMBER_ID = 25
Unknown member
RD_KAFKA_RESP_ERR_INVALID_SESSION_TIMEOUT = 26
Invalid session timeout
RD_KAFKA_RESP_ERR_REBALANCE_IN_PROGRESS = 27
Group rebalance in progress
RD_KAFKA_RESP_ERR_INVALID_COMMIT_OFFSET_SIZE = 28
Commit offset data size is not valid
RD_KAFKA_RESP_ERR_TOPIC_AUTHORIZATION_FAILED = 29
Topic authorization failed
RD_KAFKA_RESP_ERR_GROUP_AUTHORIZATION_FAILED = 30
Group authorization failed
RD_KAFKA_RESP_ERR_CLUSTER_AUTHORIZATION_FAILED = 31
Cluster authorization failed
RD_KAFKA_RESP_ERR_INVALID_TIMESTAMP = 32
Invalid timestamp
RD_KAFKA_RESP_ERR_UNSUPPORTED_SASL_MECHANISM = 33
Unsupported SASL mechanism
RD_KAFKA_RESP_ERR_ILLEGAL_SASL_STATE = 34
Illegal SASL state
RD_KAFKA_RESP_ERR_UNSUPPORTED_VERSION = 35
Unuspported version
RD_KAFKA_RESP_ERR_TOPIC_ALREADY_EXISTS = 36
Topic already exists
RD_KAFKA_RESP_ERR_INVALID_PARTITIONS = 37
Invalid number of partitions
RD_KAFKA_RESP_ERR_INVALID_REPLICATION_FACTOR = 38
Invalid replication factor
RD_KAFKA_RESP_ERR_INVALID_REPLICA_ASSIGNMENT = 39
Invalid replica assignment
RD_KAFKA_RESP_ERR_INVALID_CONFIG = 40
Invalid config
RD_KAFKA_RESP_ERR_NOT_CONTROLLER = 41
Not controller for cluster
RD_KAFKA_RESP_ERR_INVALID_REQUEST = 42
Invalid request
RD_KAFKA_RESP_ERR_UNSUPPORTED_FOR_MESSAGE_FORMAT = 43
Message format on broker does not support request
RD_KAFKA_RESP_ERR_POLICY_VIOLATION = 44
Policy violation
RD_KAFKA_RESP_ERR_OUT_OF_ORDER_SEQUENCE_NUMBER = 45
Broker received an out of order sequence number
RD_KAFKA_RESP_ERR_DUPLICATE_SEQUENCE_NUMBER = 46
Broker received a duplicate sequence number
RD_KAFKA_RESP_ERR_INVALID_PRODUCER_EPOCH = 47
Producer attempted an operation with an old epoch
RD_KAFKA_RESP_ERR_INVALID_TXN_STATE = 48
Producer attempted a transactional operation in an invalid state
RD_KAFKA_RESP_ERR_INVALID_PRODUCER_ID_MAPPING = 49
Producer attempted to use a producer id which is not currently assigned to its transactional id
RD_KAFKA_RESP_ERR_INVALID_TRANSACTION_TIMEOUT = 50
Transaction timeout is larger than the maximum value allowed by the broker’s max.transaction.timeout.ms
RD_KAFKA_RESP_ERR_CONCURRENT_TRANSACTIONS = 51
Producer attempted to update a transaction while another concurrent operation on the same transaction was ongoing
RD_KAFKA_RESP_ERR_TRANSACTION_COORDINATOR_FENCED = 52
Indicates that the transaction coordinator sending a WriteTxnMarker is no longer the current coordinator for a given producer
RD_KAFKA_RESP_ERR_TRANSACTIONAL_ID_AUTHORIZATION_FAILED = 53
Transactional Id authorization failed
RD_KAFKA_RESP_ERR_SECURITY_DISABLED = 54
Security features are disabled
RD_KAFKA_RESP_ERR_OPERATION_NOT_ATTEMPTED = 55
Operation not attempted
RD_KAFKA_RESP_ERR_KAFKA_STORAGE_ERROR = 56
Disk error when trying to access log file on the disk
RD_KAFKA_RESP_ERR_LOG_DIR_NOT_FOUND = 57
The user-specified log directory is not found in the broker config
RD_KAFKA_RESP_ERR_SASL_AUTHENTICATION_FAILED = 58
SASL Authentication failed
RD_KAFKA_RESP_ERR_UNKNOWN_PRODUCER_ID = 59
Unknown Producer Id
RD_KAFKA_RESP_ERR_REASSIGNMENT_IN_PROGRESS = 60
Partition reassignment is in progress
RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_AUTH_DISABLED = 61
Delegation Token feature is not enabled
RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_NOT_FOUND = 62
Delegation Token is not found on server
RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_OWNER_MISMATCH = 63
Specified Principal is not valid Owner/Renewer
RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_REQUEST_NOT_ALLOWED = 64
Delegation Token requests are not allowed on this connection
RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_AUTHORIZATION_FAILED = 65
Delegation Token authorization failed
RD_KAFKA_RESP_ERR_DELEGATION_TOKEN_EXPIRED = 66
Delegation Token is expired
RD_KAFKA_RESP_ERR_INVALID_PRINCIPAL_TYPE = 67
Supplied principalType is not supported
RD_KAFKA_RESP_ERR_NON_EMPTY_GROUP = 68
The group is not empty
RD_KAFKA_RESP_ERR_GROUP_ID_NOT_FOUND = 69
The group id does not exist
RD_KAFKA_RESP_ERR_FETCH_SESSION_ID_NOT_FOUND = 70
The fetch session ID was not found
RD_KAFKA_RESP_ERR_INVALID_FETCH_SESSION_EPOCH = 71
The fetch session epoch is invalid
RD_KAFKA_RESP_ERR_LISTENER_NOT_FOUND = 72
No matching listener
RD_KAFKA_RESP_ERR_TOPIC_DELETION_DISABLED = 73
Topic deletion is disabled
RD_KAFKA_RESP_ERR_FENCED_LEADER_EPOCH = 74
Leader epoch is older than broker epoch
RD_KAFKA_RESP_ERR_UNKNOWN_LEADER_EPOCH = 75
Leader epoch is newer than broker epoch
RD_KAFKA_RESP_ERR_UNSUPPORTED_COMPRESSION_TYPE = 76
Unsupported compression type
RD_KAFKA_RESP_ERR_STALE_BROKER_EPOCH = 77
Broker epoch has changed
RD_KAFKA_RESP_ERR_OFFSET_NOT_AVAILABLE = 78
Leader high watermark is not caught up
RD_KAFKA_RESP_ERR_MEMBER_ID_REQUIRED = 79
Group member needs a valid member ID
RD_KAFKA_RESP_ERR_PREFERRED_LEADER_NOT_AVAILABLE = 80
Preferred leader was not available
RD_KAFKA_RESP_ERR_GROUP_MAX_SIZE_REACHED = 81
Consumer group has reached maximum size
RD_KAFKA_RESP_ERR_FENCED_INSTANCE_ID = 82
Static consumer fenced by other consumer with same group.instance.id.
RD_KAFKA_RESP_ERR_ELIGIBLE_LEADERS_NOT_AVAILABLE = 83
Eligible partition leaders are not available
RD_KAFKA_RESP_ERR_ELECTION_NOT_NEEDED = 84
Leader election not needed for topic partition
RD_KAFKA_RESP_ERR_NO_REASSIGNMENT_IN_PROGRESS = 85
No partition reassignment is in progress
RD_KAFKA_RESP_ERR_GROUP_SUBSCRIBED_TO_TOPIC = 86
Deleting offsets of a topic while the consumer group is subscribed to it
RD_KAFKA_RESP_ERR_INVALID_RECORD = 87
Broker failed to validate record
RD_KAFKA_RESP_ERR_UNSTABLE_OFFSET_COMMIT = 88
There are unstable offsets that need to be cleared
RD_KAFKA_RESP_ERR_THROTTLING_QUOTA_EXCEEDED = 89
Throttling quota has been exceeded
RD_KAFKA_RESP_ERR_PRODUCER_FENCED = 90
There is a newer producer with the same transactionalId which fences the current one
RD_KAFKA_RESP_ERR_RESOURCE_NOT_FOUND = 91
Request illegally referred to resource that does not exist
RD_KAFKA_RESP_ERR_DUPLICATE_RESOURCE = 92
Request illegally referred to the same resource twice
RD_KAFKA_RESP_ERR_UNACCEPTABLE_CREDENTIAL = 93
Requested credential would not meet criteria for acceptability
RD_KAFKA_RESP_ERR_INCONSISTENT_VOTER_SET = 94
Indicates that the either the sender or recipient of a voter-only request is not one of the expected voters
RD_KAFKA_RESP_ERR_INVALID_UPDATE_VERSION = 95
Invalid update version
RD_KAFKA_RESP_ERR_FEATURE_UPDATE_FAILED = 96
Unable to update finalized features due to server error
RD_KAFKA_RESP_ERR_PRINCIPAL_DESERIALIZATION_FAILURE = 97
Request principal deserialization failed during forwarding
RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_ID = 100
Unknown Topic Id
RD_KAFKA_RESP_ERR_FENCED_MEMBER_EPOCH = 110
The member epoch is fenced by the group coordinator
RD_KAFKA_RESP_ERR_UNRELEASED_INSTANCE_ID = 111
The instance ID is still used by another member in the consumer group
RD_KAFKA_RESP_ERR_UNSUPPORTED_ASSIGNOR = 112
The assignor or its version range is not supported by the consumer group
RD_KAFKA_RESP_ERR_STALE_MEMBER_EPOCH = 113
The member epoch is stale
RD_KAFKA_RESP_ERR_UNKNOWN_SUBSCRIPTION_ID = 117
Client sent a push telemetry request with an invalid or outdated subscription ID.
RD_KAFKA_RESP_ERR_TELEMETRY_TOO_LARGE = 118
Client sent a push telemetry request larger than the maximum size the broker will accept.
RD_KAFKA_RESP_ERR_REBOOTSTRAP_REQUIRED = 129
Client metadata is stale, client should rebootstrap to obtain new metadata.
RD_KAFKA_RESP_ERR_END_ALL = 130
Client metadata is stale, client should rebootstrap to obtain new metadata.
Trait Implementations§
Source§impl Clone for rd_kafka_resp_err_t
impl Clone for rd_kafka_resp_err_t
Source§fn clone(&self) -> rd_kafka_resp_err_t
fn clone(&self) -> rd_kafka_resp_err_t
1.0.0 · Source§fn clone_from(&mut self, source: &Self)
fn clone_from(&mut self, source: &Self)
source. Read more