You can not select more than 25 topics
Topics must start with a letter or number, can include dashes ('-') and can be up to 35 characters long.
345 lines
14 KiB
345 lines
14 KiB
// ====== Generated from librdkafka 1.6.1 file src-cpp/rdkafkacpp.h ======
|
|
export const CODES: { ERRORS: {
|
|
/* Internal errors to rdkafka: */
|
|
/** Begin internal error codes (**-200**) */
|
|
ERR__BEGIN: number,
|
|
/** Received message is incorrect (**-199**) */
|
|
ERR__BAD_MSG: number,
|
|
/** Bad/unknown compression (**-198**) */
|
|
ERR__BAD_COMPRESSION: number,
|
|
/** Broker is going away (**-197**) */
|
|
ERR__DESTROY: number,
|
|
/** Generic failure (**-196**) */
|
|
ERR__FAIL: number,
|
|
/** Broker transport failure (**-195**) */
|
|
ERR__TRANSPORT: number,
|
|
/** Critical system resource (**-194**) */
|
|
ERR__CRIT_SYS_RESOURCE: number,
|
|
/** Failed to resolve broker (**-193**) */
|
|
ERR__RESOLVE: number,
|
|
/** Produced message timed out (**-192**) */
|
|
ERR__MSG_TIMED_OUT: 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 (**-191**) */
|
|
ERR__PARTITION_EOF: number,
|
|
/** Permanent: Partition does not exist in cluster (**-190**) */
|
|
ERR__UNKNOWN_PARTITION: number,
|
|
/** File or filesystem error (**-189**) */
|
|
ERR__FS: number,
|
|
/** Permanent: Topic does not exist in cluster (**-188**) */
|
|
ERR__UNKNOWN_TOPIC: number,
|
|
/** All broker connections are down (**-187**) */
|
|
ERR__ALL_BROKERS_DOWN: number,
|
|
/** Invalid argument, or invalid configuration (**-186**) */
|
|
ERR__INVALID_ARG: number,
|
|
/** Operation timed out (**-185**) */
|
|
ERR__TIMED_OUT: number,
|
|
/** Queue is full (**-184**) */
|
|
ERR__QUEUE_FULL: number,
|
|
/** ISR count < required.acks (**-183**) */
|
|
ERR__ISR_INSUFF: number,
|
|
/** Broker node update (**-182**) */
|
|
ERR__NODE_UPDATE: number,
|
|
/** SSL error (**-181**) */
|
|
ERR__SSL: number,
|
|
/** Waiting for coordinator to become available (**-180**) */
|
|
ERR__WAIT_COORD: number,
|
|
/** Unknown client group (**-179**) */
|
|
ERR__UNKNOWN_GROUP: number,
|
|
/** Operation in progress (**-178**) */
|
|
ERR__IN_PROGRESS: number,
|
|
/** Previous operation in progress, wait for it to finish (**-177**) */
|
|
ERR__PREV_IN_PROGRESS: number,
|
|
/** This operation would interfere with an existing subscription (**-176**) */
|
|
ERR__EXISTING_SUBSCRIPTION: number,
|
|
/** Assigned partitions (rebalance_cb) (**-175**) */
|
|
ERR__ASSIGN_PARTITIONS: number,
|
|
/** Revoked partitions (rebalance_cb) (**-174**) */
|
|
ERR__REVOKE_PARTITIONS: number,
|
|
/** Conflicting use (**-173**) */
|
|
ERR__CONFLICT: number,
|
|
/** Wrong state (**-172**) */
|
|
ERR__STATE: number,
|
|
/** Unknown protocol (**-171**) */
|
|
ERR__UNKNOWN_PROTOCOL: number,
|
|
/** Not implemented (**-170**) */
|
|
ERR__NOT_IMPLEMENTED: number,
|
|
/** Authentication failure (**-169**) */
|
|
ERR__AUTHENTICATION: number,
|
|
/** No stored offset (**-168**) */
|
|
ERR__NO_OFFSET: number,
|
|
/** Outdated (**-167**) */
|
|
ERR__OUTDATED: number,
|
|
/** Timed out in queue (**-166**) */
|
|
ERR__TIMED_OUT_QUEUE: number,
|
|
/** Feature not supported by broker (**-165**) */
|
|
ERR__UNSUPPORTED_FEATURE: number,
|
|
/** Awaiting cache update (**-164**) */
|
|
ERR__WAIT_CACHE: number,
|
|
/** Operation interrupted (**-163**) */
|
|
ERR__INTR: number,
|
|
/** Key serialization error (**-162**) */
|
|
ERR__KEY_SERIALIZATION: number,
|
|
/** Value serialization error (**-161**) */
|
|
ERR__VALUE_SERIALIZATION: number,
|
|
/** Key deserialization error (**-160**) */
|
|
ERR__KEY_DESERIALIZATION: number,
|
|
/** Value deserialization error (**-159**) */
|
|
ERR__VALUE_DESERIALIZATION: number,
|
|
/** Partial response (**-158**) */
|
|
ERR__PARTIAL: number,
|
|
/** Modification attempted on read-only object (**-157**) */
|
|
ERR__READ_ONLY: number,
|
|
/** No such entry / item not found (**-156**) */
|
|
ERR__NOENT: number,
|
|
/** Read underflow (**-155**) */
|
|
ERR__UNDERFLOW: number,
|
|
/** Invalid type (**-154**) */
|
|
ERR__INVALID_TYPE: number,
|
|
/** Retry operation (**-153**) */
|
|
ERR__RETRY: number,
|
|
/** Purged in queue (**-152**) */
|
|
ERR__PURGE_QUEUE: number,
|
|
/** Purged in flight (**-151**) */
|
|
ERR__PURGE_INFLIGHT: number,
|
|
/** Fatal error: see RdKafka::Handle::fatal_error() (**-150**) */
|
|
ERR__FATAL: number,
|
|
/** Inconsistent state (**-149**) */
|
|
ERR__INCONSISTENT: number,
|
|
/** Gap-less ordering would not be guaranteed if proceeding (**-148**) */
|
|
ERR__GAPLESS_GUARANTEE: number,
|
|
/** Maximum poll interval exceeded (**-147**) */
|
|
ERR__MAX_POLL_EXCEEDED: number,
|
|
/** Unknown broker (**-146**) */
|
|
ERR__UNKNOWN_BROKER: number,
|
|
/** Functionality not configured (**-145**) */
|
|
ERR__NOT_CONFIGURED: number,
|
|
/** Instance has been fenced (**-144**) */
|
|
ERR__FENCED: number,
|
|
/** Application generated error (**-143**) */
|
|
ERR__APPLICATION: number,
|
|
/** Assignment lost (**-142**) */
|
|
ERR__ASSIGNMENT_LOST: number,
|
|
/** No operation performed (**-141**) */
|
|
ERR__NOOP: number,
|
|
/** No offset to automatically reset to (**-140**) */
|
|
ERR__AUTO_OFFSET_RESET: number,
|
|
/** End internal error codes (**-100**) */
|
|
ERR__END: number,
|
|
/* Kafka broker errors: */
|
|
/** Unknown broker error (**-1**) */
|
|
ERR_UNKNOWN: number,
|
|
/** Success (**0**) */
|
|
ERR_NO_ERROR: number,
|
|
/** Offset out of range (**1**) */
|
|
ERR_OFFSET_OUT_OF_RANGE: number,
|
|
/** Invalid message (**2**) */
|
|
ERR_INVALID_MSG: number,
|
|
/** Unknown topic or partition (**3**) */
|
|
ERR_UNKNOWN_TOPIC_OR_PART: number,
|
|
/** Invalid message size (**4**) */
|
|
ERR_INVALID_MSG_SIZE: number,
|
|
/** Leader not available (**5**) */
|
|
ERR_LEADER_NOT_AVAILABLE: number,
|
|
/** Not leader for partition (**6**) */
|
|
ERR_NOT_LEADER_FOR_PARTITION: number,
|
|
/** Request timed out (**7**) */
|
|
ERR_REQUEST_TIMED_OUT: number,
|
|
/** Broker not available (**8**) */
|
|
ERR_BROKER_NOT_AVAILABLE: number,
|
|
/** Replica not available (**9**) */
|
|
ERR_REPLICA_NOT_AVAILABLE: number,
|
|
/** Message size too large (**10**) */
|
|
ERR_MSG_SIZE_TOO_LARGE: number,
|
|
/** StaleControllerEpochCode (**11**) */
|
|
ERR_STALE_CTRL_EPOCH: number,
|
|
/** Offset metadata string too large (**12**) */
|
|
ERR_OFFSET_METADATA_TOO_LARGE: number,
|
|
/** Broker disconnected before response received (**13**) */
|
|
ERR_NETWORK_EXCEPTION: number,
|
|
/** Coordinator load in progress (**14**) */
|
|
ERR_COORDINATOR_LOAD_IN_PROGRESS: number,
|
|
/** Group coordinator load in progress (**14**) */
|
|
ERR_GROUP_LOAD_IN_PROGRESS: number,
|
|
/** Coordinator not available (**15**) */
|
|
ERR_COORDINATOR_NOT_AVAILABLE: number,
|
|
/** Group coordinator not available (**15**) */
|
|
ERR_GROUP_COORDINATOR_NOT_AVAILABLE: number,
|
|
/** Not coordinator (**16**) */
|
|
ERR_NOT_COORDINATOR: number,
|
|
/** Not coordinator for group (**16**) */
|
|
ERR_NOT_COORDINATOR_FOR_GROUP: number,
|
|
/** Invalid topic (**17**) */
|
|
ERR_TOPIC_EXCEPTION: number,
|
|
/** Message batch larger than configured server segment size (**18**) */
|
|
ERR_RECORD_LIST_TOO_LARGE: number,
|
|
/** Not enough in-sync replicas (**19**) */
|
|
ERR_NOT_ENOUGH_REPLICAS: number,
|
|
/** Message(s) written to insufficient number of in-sync replicas (**20**) */
|
|
ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND: number,
|
|
/** Invalid required acks value (**21**) */
|
|
ERR_INVALID_REQUIRED_ACKS: number,
|
|
/** Specified group generation id is not valid (**22**) */
|
|
ERR_ILLEGAL_GENERATION: number,
|
|
/** Inconsistent group protocol (**23**) */
|
|
ERR_INCONSISTENT_GROUP_PROTOCOL: number,
|
|
/** Invalid group.id (**24**) */
|
|
ERR_INVALID_GROUP_ID: number,
|
|
/** Unknown member (**25**) */
|
|
ERR_UNKNOWN_MEMBER_ID: number,
|
|
/** Invalid session timeout (**26**) */
|
|
ERR_INVALID_SESSION_TIMEOUT: number,
|
|
/** Group rebalance in progress (**27**) */
|
|
ERR_REBALANCE_IN_PROGRESS: number,
|
|
/** Commit offset data size is not valid (**28**) */
|
|
ERR_INVALID_COMMIT_OFFSET_SIZE: number,
|
|
/** Topic authorization failed (**29**) */
|
|
ERR_TOPIC_AUTHORIZATION_FAILED: number,
|
|
/** Group authorization failed (**30**) */
|
|
ERR_GROUP_AUTHORIZATION_FAILED: number,
|
|
/** Cluster authorization failed (**31**) */
|
|
ERR_CLUSTER_AUTHORIZATION_FAILED: number,
|
|
/** Invalid timestamp (**32**) */
|
|
ERR_INVALID_TIMESTAMP: number,
|
|
/** Unsupported SASL mechanism (**33**) */
|
|
ERR_UNSUPPORTED_SASL_MECHANISM: number,
|
|
/** Illegal SASL state (**34**) */
|
|
ERR_ILLEGAL_SASL_STATE: number,
|
|
/** Unuspported version (**35**) */
|
|
ERR_UNSUPPORTED_VERSION: number,
|
|
/** Topic already exists (**36**) */
|
|
ERR_TOPIC_ALREADY_EXISTS: number,
|
|
/** Invalid number of partitions (**37**) */
|
|
ERR_INVALID_PARTITIONS: number,
|
|
/** Invalid replication factor (**38**) */
|
|
ERR_INVALID_REPLICATION_FACTOR: number,
|
|
/** Invalid replica assignment (**39**) */
|
|
ERR_INVALID_REPLICA_ASSIGNMENT: number,
|
|
/** Invalid config (**40**) */
|
|
ERR_INVALID_CONFIG: number,
|
|
/** Not controller for cluster (**41**) */
|
|
ERR_NOT_CONTROLLER: number,
|
|
/** Invalid request (**42**) */
|
|
ERR_INVALID_REQUEST: number,
|
|
/** Message format on broker does not support request (**43**) */
|
|
ERR_UNSUPPORTED_FOR_MESSAGE_FORMAT: number,
|
|
/** Policy violation (**44**) */
|
|
ERR_POLICY_VIOLATION: number,
|
|
/** Broker received an out of order sequence number (**45**) */
|
|
ERR_OUT_OF_ORDER_SEQUENCE_NUMBER: number,
|
|
/** Broker received a duplicate sequence number (**46**) */
|
|
ERR_DUPLICATE_SEQUENCE_NUMBER: number,
|
|
/** Producer attempted an operation with an old epoch (**47**) */
|
|
ERR_INVALID_PRODUCER_EPOCH: number,
|
|
/** Producer attempted a transactional operation in an invalid state (**48**) */
|
|
ERR_INVALID_TXN_STATE: number,
|
|
/** Producer attempted to use a producer id which is not
|
|
* currently assigned to its transactional id (**49**) */
|
|
ERR_INVALID_PRODUCER_ID_MAPPING: number,
|
|
/** Transaction timeout is larger than the maximum
|
|
* value allowed by the broker's max.transaction.timeout.ms (**50**) */
|
|
ERR_INVALID_TRANSACTION_TIMEOUT: number,
|
|
/** Producer attempted to update a transaction while another
|
|
* concurrent operation on the same transaction was ongoing (**51**) */
|
|
ERR_CONCURRENT_TRANSACTIONS: number,
|
|
/** Indicates that the transaction coordinator sending a
|
|
* WriteTxnMarker is no longer the current coordinator for a
|
|
* given producer (**52**) */
|
|
ERR_TRANSACTION_COORDINATOR_FENCED: number,
|
|
/** Transactional Id authorization failed (**53**) */
|
|
ERR_TRANSACTIONAL_ID_AUTHORIZATION_FAILED: number,
|
|
/** Security features are disabled (**54**) */
|
|
ERR_SECURITY_DISABLED: number,
|
|
/** Operation not attempted (**55**) */
|
|
ERR_OPERATION_NOT_ATTEMPTED: number,
|
|
/** Disk error when trying to access log file on the disk (**56**) */
|
|
ERR_KAFKA_STORAGE_ERROR: number,
|
|
/** The user-specified log directory is not found in the broker config (**57**) */
|
|
ERR_LOG_DIR_NOT_FOUND: number,
|
|
/** SASL Authentication failed (**58**) */
|
|
ERR_SASL_AUTHENTICATION_FAILED: number,
|
|
/** Unknown Producer Id (**59**) */
|
|
ERR_UNKNOWN_PRODUCER_ID: number,
|
|
/** Partition reassignment is in progress (**60**) */
|
|
ERR_REASSIGNMENT_IN_PROGRESS: number,
|
|
/** Delegation Token feature is not enabled (**61**) */
|
|
ERR_DELEGATION_TOKEN_AUTH_DISABLED: number,
|
|
/** Delegation Token is not found on server (**62**) */
|
|
ERR_DELEGATION_TOKEN_NOT_FOUND: number,
|
|
/** Specified Principal is not valid Owner/Renewer (**63**) */
|
|
ERR_DELEGATION_TOKEN_OWNER_MISMATCH: number,
|
|
/** Delegation Token requests are not allowed on this connection (**64**) */
|
|
ERR_DELEGATION_TOKEN_REQUEST_NOT_ALLOWED: number,
|
|
/** Delegation Token authorization failed (**65**) */
|
|
ERR_DELEGATION_TOKEN_AUTHORIZATION_FAILED: number,
|
|
/** Delegation Token is expired (**66**) */
|
|
ERR_DELEGATION_TOKEN_EXPIRED: number,
|
|
/** Supplied principalType is not supported (**67**) */
|
|
ERR_INVALID_PRINCIPAL_TYPE: number,
|
|
/** The group is not empty (**68**) */
|
|
ERR_NON_EMPTY_GROUP: number,
|
|
/** The group id does not exist (**69**) */
|
|
ERR_GROUP_ID_NOT_FOUND: number,
|
|
/** The fetch session ID was not found (**70**) */
|
|
ERR_FETCH_SESSION_ID_NOT_FOUND: number,
|
|
/** The fetch session epoch is invalid (**71**) */
|
|
ERR_INVALID_FETCH_SESSION_EPOCH: number,
|
|
/** No matching listener (**72**) */
|
|
ERR_LISTENER_NOT_FOUND: number,
|
|
/** Topic deletion is disabled (**73**) */
|
|
ERR_TOPIC_DELETION_DISABLED: number,
|
|
/** Leader epoch is older than broker epoch (**74**) */
|
|
ERR_FENCED_LEADER_EPOCH: number,
|
|
/** Leader epoch is newer than broker epoch (**75**) */
|
|
ERR_UNKNOWN_LEADER_EPOCH: number,
|
|
/** Unsupported compression type (**76**) */
|
|
ERR_UNSUPPORTED_COMPRESSION_TYPE: number,
|
|
/** Broker epoch has changed (**77**) */
|
|
ERR_STALE_BROKER_EPOCH: number,
|
|
/** Leader high watermark is not caught up (**78**) */
|
|
ERR_OFFSET_NOT_AVAILABLE: number,
|
|
/** Group member needs a valid member ID (**79**) */
|
|
ERR_MEMBER_ID_REQUIRED: number,
|
|
/** Preferred leader was not available (**80**) */
|
|
ERR_PREFERRED_LEADER_NOT_AVAILABLE: number,
|
|
/** Consumer group has reached maximum size (**81**) */
|
|
ERR_GROUP_MAX_SIZE_REACHED: number,
|
|
/** Static consumer fenced by other consumer with same
|
|
* group.instance.id (**82**) */
|
|
ERR_FENCED_INSTANCE_ID: number,
|
|
/** Eligible partition leaders are not available (**83**) */
|
|
ERR_ELIGIBLE_LEADERS_NOT_AVAILABLE: number,
|
|
/** Leader election not needed for topic partition (**84**) */
|
|
ERR_ELECTION_NOT_NEEDED: number,
|
|
/** No partition reassignment is in progress (**85**) */
|
|
ERR_NO_REASSIGNMENT_IN_PROGRESS: number,
|
|
/** Deleting offsets of a topic while the consumer group is
|
|
* subscribed to it (**86**) */
|
|
ERR_GROUP_SUBSCRIBED_TO_TOPIC: number,
|
|
/** Broker failed to validate record (**87**) */
|
|
ERR_INVALID_RECORD: number,
|
|
/** There are unstable offsets that need to be cleared (**88**) */
|
|
ERR_UNSTABLE_OFFSET_COMMIT: number,
|
|
/** Throttling quota has been exceeded (**89**) */
|
|
ERR_THROTTLING_QUOTA_EXCEEDED: number,
|
|
/** There is a newer producer with the same transactionalId
|
|
* which fences the current one (**90**) */
|
|
ERR_PRODUCER_FENCED: number,
|
|
/** Request illegally referred to resource that does not exist (**91**) */
|
|
ERR_RESOURCE_NOT_FOUND: number,
|
|
/** Request illegally referred to the same resource twice (**92**) */
|
|
ERR_DUPLICATE_RESOURCE: number,
|
|
/** Requested credential would not meet criteria for acceptability (**93**) */
|
|
ERR_UNACCEPTABLE_CREDENTIAL: number,
|
|
/** Indicates that the either the sender or recipient of a
|
|
* voter-only request is not one of the expected voters (**94**) */
|
|
ERR_INCONSISTENT_VOTER_SET: number,
|
|
/** Invalid update version (**95**) */
|
|
ERR_INVALID_UPDATE_VERSION: number,
|
|
/** Unable to update finalized features due to server error (**96**) */
|
|
ERR_FEATURE_UPDATE_FAILED: number,
|
|
/** Request principal deserialization failed during forwarding (**97**) */
|
|
ERR_PRINCIPAL_DESERIALIZATION_FAILURE: number,
|
|
}}
|