Class: LibrdKafkaError

LibrdKafkaError

new LibrdKafkaError(e)

Representation of a librdkafka error This can be created by giving either another error to piggy-back on. In this situation it tries to parse the error string to figure out the intent. However, more usually, it is constructed by an error object created by a C++ Baton.

Parameters:

Name Type Description
e object | error An object or error to wrap
Properties:
Name Type Description
message string The error message
code number The error code.
origin string The origin, whether it is local or remote
Source:

(static, constant) codes :number

Enum for identifying errors reported by the library You can find this list in the C++ code at https://github.com/edenhill/librdkafka/blob/master/src-cpp/rdkafkacpp.h#L148

Type:
  • number
Properties:
Name Type Description
ERR__BEGIN number Begin internal error codes
ERR__BAD_MSG number Received message is incorrect
ERR__BAD_COMPRESSION number Bad/unknown compression
ERR__DESTROY number Broker is going away
ERR__FAIL number Generic failure
ERR__TRANSPORT number Broker transport failure
ERR__CRIT_SYS_RESOURCE number Critical system resource
ERR__RESOLVE number Failed to resolve broker
ERR__MSG_TIMED_OUT number Produced message timed out
ERR__PARTITION_EOF number 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.
ERR__UNKNOWN_PARTITION number Permanent: Partition does not exist in cluster.
ERR__FS number File or filesystem error
ERR__UNKNOWN_TOPIC number Permanent: Topic does not exist in cluster.
ERR__ALL_BROKERS_DOWN number All broker connections are down.
ERR__INVALID_ARG number Invalid argument, or invalid configuration
ERR__TIMED_OUT number Operation timed out
ERR__QUEUE_FULL number Queue is full
ERR__ISR_INSUFF number ISR count < required.acks
ERR__NODE_UPDATE number Broker node update
ERR__SSL number SSL error
ERR__WAIT_COORD number Waiting for coordinator to become available.
ERR__UNKNOWN_GROUP number Unknown client group
ERR__IN_PROGRESS number Operation in progress
ERR__PREV_IN_PROGRESS number Previous operation in progress, wait for it to finish.
ERR__EXISTING_SUBSCRIPTION number This operation would interfere with an existing subscription
ERR__ASSIGN_PARTITIONS number Assigned partitions (rebalance_cb)
ERR__REVOKE_PARTITIONS number Revoked partitions (rebalance_cb)
ERR__CONFLICT number Conflicting use
ERR__STATE number Wrong state
ERR__UNKNOWN_PROTOCOL number Unknown protocol
ERR__NOT_IMPLEMENTED number Not implemented
ERR__AUTHENTICATION number Authentication failure
ERR__NO_OFFSET number No stored offset
ERR__OUTDATED number Outdated
ERR__TIMED_OUT_QUEUE number Timed out in queue
ERR__UNSUPPORTED_FEATURE number Feature not supported by broker
ERR__WAIT_CACHE number Awaiting cache update
ERR__INTR number Operation interrupted
ERR__KEY_SERIALIZATION number Key serialization error
ERR__VALUE_SERIALIZATION number Value serialization error
ERR__KEY_DESERIALIZATION number Key deserialization error
ERR__VALUE_DESERIALIZATION number Value deserialization error
ERR__PARTIAL number Partial response
ERR__READ_ONLY number Modification attempted on read-only object
ERR__NOENT number No such entry / item not found
ERR__UNDERFLOW number Read underflow
ERR__INVALID_TYPE number Invalid type
ERR__RETRY number Retry operation
ERR__PURGE_QUEUE number Purged in queue
ERR__PURGE_INFLIGHT number Purged in flight
ERR__FATAL number Fatal error: see RdKafka::Handle::fatal_error()
ERR__INCONSISTENT number Inconsistent state
ERR__GAPLESS_GUARANTEE number Gap-less ordering would not be guaranteed if proceeding
ERR__MAX_POLL_EXCEEDED number Maximum poll interval exceeded
ERR__UNKNOWN_BROKER number Unknown broker
ERR__NOT_CONFIGURED number Functionality not configured
ERR__FENCED number Instance has been fenced
ERR__APPLICATION number Application generated error
ERR__ASSIGNMENT_LOST number Assignment lost
ERR__NOOP number No operation performed
ERR__AUTO_OFFSET_RESET number No offset to automatically reset to
ERR__LOG_TRUNCATION number Partition log truncation detected
ERR__END number End internal error codes
ERR_UNKNOWN number Unknown broker error
ERR_NO_ERROR number Success
ERR_OFFSET_OUT_OF_RANGE number Offset out of range
ERR_INVALID_MSG number Invalid message
ERR_UNKNOWN_TOPIC_OR_PART number Unknown topic or partition
ERR_INVALID_MSG_SIZE number Invalid message size
ERR_LEADER_NOT_AVAILABLE number Leader not available
ERR_NOT_LEADER_FOR_PARTITION number Not leader for partition
ERR_REQUEST_TIMED_OUT number Request timed out
ERR_BROKER_NOT_AVAILABLE number Broker not available
ERR_REPLICA_NOT_AVAILABLE number Replica not available
ERR_MSG_SIZE_TOO_LARGE number Message size too large
ERR_STALE_CTRL_EPOCH number StaleControllerEpochCode
ERR_OFFSET_METADATA_TOO_LARGE number Offset metadata string too large
ERR_NETWORK_EXCEPTION number Broker disconnected before response received
ERR_COORDINATOR_LOAD_IN_PROGRESS number Coordinator load in progress
ERR_GROUP_LOAD_IN_PROGRESS number Group coordinator load in progress
ERR_COORDINATOR_NOT_AVAILABLE number Coordinator not available
ERR_GROUP_COORDINATOR_NOT_AVAILABLE number Group coordinator not available
ERR_NOT_COORDINATOR number Not coordinator
ERR_NOT_COORDINATOR_FOR_GROUP number Not coordinator for group
ERR_TOPIC_EXCEPTION number Invalid topic
ERR_RECORD_LIST_TOO_LARGE number Message batch larger than configured server segment size
ERR_NOT_ENOUGH_REPLICAS number Not enough in-sync replicas
ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND number Message(s) written to insufficient number of in-sync replicas
ERR_INVALID_REQUIRED_ACKS number Invalid required acks value
ERR_ILLEGAL_GENERATION number Specified group generation id is not valid
ERR_INCONSISTENT_GROUP_PROTOCOL number Inconsistent group protocol
ERR_INVALID_GROUP_ID number Invalid group.id
ERR_UNKNOWN_MEMBER_ID number Unknown member
ERR_INVALID_SESSION_TIMEOUT number Invalid session timeout
ERR_REBALANCE_IN_PROGRESS number Group rebalance in progress
ERR_INVALID_COMMIT_OFFSET_SIZE number Commit offset data size is not valid
ERR_TOPIC_AUTHORIZATION_FAILED number Topic authorization failed
ERR_GROUP_AUTHORIZATION_FAILED number Group authorization failed
ERR_CLUSTER_AUTHORIZATION_FAILED number Cluster authorization failed
ERR_INVALID_TIMESTAMP number Invalid timestamp
ERR_UNSUPPORTED_SASL_MECHANISM number Unsupported SASL mechanism
ERR_ILLEGAL_SASL_STATE number Illegal SASL state
ERR_UNSUPPORTED_VERSION number Unuspported version
ERR_TOPIC_ALREADY_EXISTS number Topic already exists
ERR_INVALID_PARTITIONS number Invalid number of partitions
ERR_INVALID_REPLICATION_FACTOR number Invalid replication factor
ERR_INVALID_REPLICA_ASSIGNMENT number Invalid replica assignment
ERR_INVALID_CONFIG number Invalid config
ERR_NOT_CONTROLLER number Not controller for cluster
ERR_INVALID_REQUEST number Invalid request
ERR_UNSUPPORTED_FOR_MESSAGE_FORMAT number Message format on broker does not support request
ERR_POLICY_VIOLATION number Policy violation
ERR_OUT_OF_ORDER_SEQUENCE_NUMBER number Broker received an out of order sequence number
ERR_DUPLICATE_SEQUENCE_NUMBER number Broker received a duplicate sequence number
ERR_INVALID_PRODUCER_EPOCH number Producer attempted an operation with an old epoch
ERR_INVALID_TXN_STATE number Producer attempted a transactional operation in an invalid state
ERR_INVALID_PRODUCER_ID_MAPPING number Producer attempted to use a producer id which is not currently assigned to its transactional id
ERR_INVALID_TRANSACTION_TIMEOUT number Transaction timeout is larger than the maximum value allowed by the broker's max.transaction.timeout.ms
ERR_CONCURRENT_TRANSACTIONS number Producer attempted to update a transaction while another concurrent operation on the same transaction was ongoing
ERR_TRANSACTION_COORDINATOR_FENCED number Indicates that the transaction coordinator sending a WriteTxnMarker is no longer the current coordinator for a given producer
ERR_TRANSACTIONAL_ID_AUTHORIZATION_FAILED number Transactional Id authorization failed
ERR_SECURITY_DISABLED number Security features are disabled
ERR_OPERATION_NOT_ATTEMPTED number Operation not attempted
ERR_KAFKA_STORAGE_ERROR number Disk error when trying to access log file on the disk
ERR_LOG_DIR_NOT_FOUND number The user-specified log directory is not found in the broker config
ERR_SASL_AUTHENTICATION_FAILED number SASL Authentication failed
ERR_UNKNOWN_PRODUCER_ID number Unknown Producer Id
ERR_REASSIGNMENT_IN_PROGRESS number Partition reassignment is in progress
ERR_DELEGATION_TOKEN_AUTH_DISABLED number Delegation Token feature is not enabled
ERR_DELEGATION_TOKEN_NOT_FOUND number Delegation Token is not found on server
ERR_DELEGATION_TOKEN_OWNER_MISMATCH number Specified Principal is not valid Owner/Renewer
ERR_DELEGATION_TOKEN_REQUEST_NOT_ALLOWED number Delegation Token requests are not allowed on this connection
ERR_DELEGATION_TOKEN_AUTHORIZATION_FAILED number Delegation Token authorization failed
ERR_DELEGATION_TOKEN_EXPIRED number Delegation Token is expired
ERR_INVALID_PRINCIPAL_TYPE number Supplied principalType is not supported
ERR_NON_EMPTY_GROUP number The group is not empty
ERR_GROUP_ID_NOT_FOUND number The group id does not exist
ERR_FETCH_SESSION_ID_NOT_FOUND number The fetch session ID was not found
ERR_INVALID_FETCH_SESSION_EPOCH number The fetch session epoch is invalid
ERR_LISTENER_NOT_FOUND number No matching listener
ERR_TOPIC_DELETION_DISABLED number Topic deletion is disabled
ERR_FENCED_LEADER_EPOCH number Leader epoch is older than broker epoch
ERR_UNKNOWN_LEADER_EPOCH number Leader epoch is newer than broker epoch
ERR_UNSUPPORTED_COMPRESSION_TYPE number Unsupported compression type
ERR_STALE_BROKER_EPOCH number Broker epoch has changed
ERR_OFFSET_NOT_AVAILABLE number Leader high watermark is not caught up
ERR_MEMBER_ID_REQUIRED number Group member needs a valid member ID
ERR_PREFERRED_LEADER_NOT_AVAILABLE number Preferred leader was not available
ERR_GROUP_MAX_SIZE_REACHED number Consumer group has reached maximum size
ERR_FENCED_INSTANCE_ID number Static consumer fenced by other consumer with same group.instance.id.
ERR_ELIGIBLE_LEADERS_NOT_AVAILABLE number Eligible partition leaders are not available
ERR_ELECTION_NOT_NEEDED number Leader election not needed for topic partition
ERR_NO_REASSIGNMENT_IN_PROGRESS number No partition reassignment is in progress
ERR_GROUP_SUBSCRIBED_TO_TOPIC number Deleting offsets of a topic while the consumer group is subscribed to it
ERR_INVALID_RECORD number Broker failed to validate record
ERR_UNSTABLE_OFFSET_COMMIT number There are unstable offsets that need to be cleared
ERR_THROTTLING_QUOTA_EXCEEDED number Throttling quota has been exceeded
ERR_PRODUCER_FENCED number There is a newer producer with the same transactionalId which fences the current one
ERR_RESOURCE_NOT_FOUND number Request illegally referred to resource that does not exist
ERR_DUPLICATE_RESOURCE number Request illegally referred to the same resource twice
ERR_UNACCEPTABLE_CREDENTIAL number Requested credential would not meet criteria for acceptability
ERR_INCONSISTENT_VOTER_SET number Indicates that the either the sender or recipient of a voter-only request is not one of the expected voters
ERR_INVALID_UPDATE_VERSION number Invalid update version
ERR_FEATURE_UPDATE_FAILED number Unable to update finalized features due to server error
ERR_PRINCIPAL_DESERIALIZATION_FAILURE number Request principal deserialization failed during forwarding
Source: