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.
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__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_GROUP_LOAD_IN_PROGRESS number Group coordinator load in progress
ERR_GROUP_COORDINATOR_NOT_AVAILABLE number Group coordinator not available
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
Source: