Value | Meaning |
---|
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 | |
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 | 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. |
RD_KAFKA_RESP_ERR__UNKNOWN_PARTITION-190 | Permanent: Partition does not exist in cluster. |
RD_KAFKA_RESP_ERR__FS-189 | |
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 | |
RD_KAFKA_RESP_ERR__QUEUE_FULL-184 | |
RD_KAFKA_RESP_ERR__ISR_INSUFF-183 | ISR count < required.acks |
RD_KAFKA_RESP_ERR__NODE_UPDATE-182 | |
RD_KAFKA_RESP_ERR__SSL-181 | |
RD_KAFKA_RESP_ERR__WAIT_COORD-180 | Waiting for coordinator to become available. |
RD_KAFKA_RESP_ERR__UNKNOWN_GROUP-179 | |
RD_KAFKA_RESP_ERR__IN_PROGRESS-178 | |
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 | |
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 | Feature not supported by broker |
RD_KAFKA_RESP_ERR__WAIT_CACHE-164 | |
RD_KAFKA_RESP_ERR__END-100 | |
RD_KAFKA_RESP_ERR_UNKNOWN-1 | |
RD_KAFKA_RESP_ERR_NO_ERROR0 | |
RD_KAFKA_RESP_ERR_OFFSET_OUT_OF_RANGE1 | |
RD_KAFKA_RESP_ERR_INVALID_MSG2 | |
RD_KAFKA_RESP_ERR_UNKNOWN_TOPIC_OR_PART3 | Unknown topic or partition |
RD_KAFKA_RESP_ERR_INVALID_MSG_SIZE4 | |
RD_KAFKA_RESP_ERR_LEADER_NOT_AVAILABLE5 | |
RD_KAFKA_RESP_ERR_NOT_LEADER_FOR_PARTITION6 | |
RD_KAFKA_RESP_ERR_REQUEST_TIMED_OUT7 | |
RD_KAFKA_RESP_ERR_BROKER_NOT_AVAILABLE8 | |
RD_KAFKA_RESP_ERR_REPLICA_NOT_AVAILABLE9 | |
RD_KAFKA_RESP_ERR_MSG_SIZE_TOO_LARGE10 | |
RD_KAFKA_RESP_ERR_STALE_CTRL_EPOCH11 | |
RD_KAFKA_RESP_ERR_OFFSET_METADATA_TOO_LARGE12 | Offset metadata string too large |
RD_KAFKA_RESP_ERR_NETWORK_EXCEPTION13 | Broker disconnected before response received |
RD_KAFKA_RESP_ERR_GROUP_LOAD_IN_PROGRESS14 | Group coordinator load in progress |
RD_KAFKA_RESP_ERR_GROUP_COORDINATOR_NOT_AVAILABLE15 | Group coordinator not available |
RD_KAFKA_RESP_ERR_NOT_COORDINATOR_FOR_GROUP16 | Not coordinator for group |
RD_KAFKA_RESP_ERR_TOPIC_EXCEPTION17 | |
RD_KAFKA_RESP_ERR_RECORD_LIST_TOO_LARGE18 | Message batch larger than configured server segment size |
RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS19 | Not enough in-sync replicas |
RD_KAFKA_RESP_ERR_NOT_ENOUGH_REPLICAS_AFTER_APPEND20 | Message(s) written to insufficient number of in-sync replicas |
RD_KAFKA_RESP_ERR_INVALID_REQUIRED_ACKS21 | Invalid required acks value |
RD_KAFKA_RESP_ERR_ILLEGAL_GENERATION22 | Specified group generation id is not valid |
RD_KAFKA_RESP_ERR_INCONSISTENT_GROUP_PROTOCOL23 | Inconsistent group protocol |
RD_KAFKA_RESP_ERR_INVALID_GROUP_ID24 | |
RD_KAFKA_RESP_ERR_UNKNOWN_MEMBER_ID25 | |
RD_KAFKA_RESP_ERR_INVALID_SESSION_TIMEOUT26 | |
RD_KAFKA_RESP_ERR_REBALANCE_IN_PROGRESS27 | Group rebalance in progress |
RD_KAFKA_RESP_ERR_INVALID_COMMIT_OFFSET_SIZE28 | Commit offset data size is not valid |
RD_KAFKA_RESP_ERR_TOPIC_AUTHORIZATION_FAILED29 | Topic authorization failed |
RD_KAFKA_RESP_ERR_GROUP_AUTHORIZATION_FAILED30 | Group authorization failed |
RD_KAFKA_RESP_ERR_CLUSTER_AUTHORIZATION_FAILED31 | Cluster authorization failed |
RD_KAFKA_RESP_ERR_INVALID_TIMESTAMP32 | |
RD_KAFKA_RESP_ERR_UNSUPPORTED_SASL_MECHANISM33 | Unsupported SASL mechanism |
RD_KAFKA_RESP_ERR_ILLEGAL_SASL_STATE34 | |
RD_KAFKA_RESP_ERR_UNSUPPORTED_VERSION35 | |
RD_KAFKA_RESP_ERR_TOPIC_ALREADY_EXISTS36 | |
RD_KAFKA_RESP_ERR_INVALID_PARTITIONS37 | Invalid number of partitions |
RD_KAFKA_RESP_ERR_INVALID_REPLICATION_FACTOR38 | Invalid replication factor |
RD_KAFKA_RESP_ERR_INVALID_REPLICA_ASSIGNMENT39 | Invalid replica assignment |
RD_KAFKA_RESP_ERR_INVALID_CONFIG40 | |
RD_KAFKA_RESP_ERR_NOT_CONTROLLER41 | Not controller for cluster |
RD_KAFKA_RESP_ERR_INVALID_REQUEST42 | |
RD_KAFKA_RESP_ERR_UNSUPPORTED_FOR_MESSAGE_FORMAT43 | Message format on broker does not support request |
RD_KAFKA_RESP_ERR_END_ALL | |
@enum rd_kafka_resp_err_t @brief Error codes.
The negative error codes delimited by two underscores (\c RD_KAFKA_RESP_ERR__..) denotes errors internal to librdkafka and are displayed as \c \"Local: \<error string..\>\", while the error codes delimited by a single underscore (\c RD_KAFKA_RESP_ERR_..) denote broker errors and are displayed as \c \"Broker: \<error string..\>\".
@sa Use rd_kafka_err2str() to translate an error code a human readable string