kafka

Apache Kafka Error Codes

Numeric error codes returned in Kafka protocol responses. Each code has a symbolic name used in client libraries.

121 codes

references kafka.apache.org/protocol

· All codes 121 codes

BROKER_ID_NOT_REGISTERED Broker ID Not Registered The broker ID specified in the request is not registered in the cluster metadata.
BROKER_NOT_AVAILABLE Broker Not Available The broker is not available. This is a temporary condition; the broker may be starting up or shutting down.
CLUSTER_AUTHORIZATION_FAILED Cluster Authorization Failed The client is not authorised to perform the requested cluster-level operation.
CONCURRENT_TRANSACTIONS Concurrent Transactions Another transaction from the same producer is still in progress. Transactions must be completed sequentially.
COORDINATOR_LOAD_IN_PROGRESS Coordinator Load in Progress The coordinator is loading and is not yet ready to handle requests. The client should retry after a brief delay.
COORDINATOR_NOT_AVAILABLE Coordinator Not Available The group or transaction coordinator is not available. The client should find the coordinator and retry.
CORRUPT_MESSAGE Corrupt Message A message batch failed its CRC validation or contained an invalid record. The message data is corrupted.
DELEGATION_TOKEN_AUTH_DISABLED Delegation Token Auth Disabled Delegation token authentication is not enabled on this broker.
DELEGATION_TOKEN_EXPIRED Delegation Token Expired The delegation token has expired and is no longer valid. Obtain a new delegation token.
DELEGATION_TOKEN_NOT_FOUND Delegation Token Not Found The requested delegation token was not found. It may have expired or may never have existed.
DELEGATION_TOKEN_OWNER_MISMATCH Delegation Token Owner Mismatch The requester is not the owner of the delegation token and is not authorised to perform this operation on it.
DELEGATION_TOKEN_REQUEST_NOT_ALLOWED Delegation Token Request Not Allowed The delegation token request is not permitted. Delegation tokens cannot be created using another delegation token for authentication.
DUPLICATE_BROKER_REGISTRATION Duplicate Broker Registration A broker registration was attempted with an ID that is already registered. Each broker ID must be unique in the cluster.
DUPLICATE_RESOURCE Duplicate Resource The resource already exists and cannot be created again. Use a different name or update the existing resource.
DUPLICATE_SEQUENCE_NUMBER Duplicate Sequence Number The idempotent producer sent a record batch with a sequence number that has already been received and acknowledged.
ELECTION_NOT_NEEDED Election Not Needed An election was requested but was not needed because the current leader is already the preferred leader.
ELIGIBLE_LEADERS_NOT_AVAILABLE Eligible Leaders Not Available No eligible leaders are available for election for this partition. Ensure at least one replica is in-sync.
FEATURE_UPDATE_FAILED Feature Update Failed The feature version update failed. The broker may not support the requested version or the update is not allowed.
FENCED_INSTANCE_ID Fenced Instance ID The static member's instance ID has been fenced by a newer member with the same instance ID. The fenced member must rejoin.
FENCED_LEADER_EPOCH Fenced Leader Epoch The leader epoch in the request is smaller than the current leader epoch. The client has stale metadata and should refresh.
FENCED_MEMBER_EPOCH Fenced Member Epoch The member epoch in the request is fenced. The member must rejoin the group to obtain a new epoch.
FETCH_SESSION_ID_NOT_FOUND Fetch Session ID Not Found The incremental fetch session ID provided does not exist on this broker. The client should start a new fetch session.
FETCH_SESSION_TOPIC_ID_ERROR Fetch Session Topic ID Error The topic ID provided in an incremental fetch session request does not match the topic ID known to the broker.
GROUP_AUTHORIZATION_FAILED Group Authorization Failed The client is not authorised to access the consumer group.
GROUP_ID_NOT_FOUND Group ID Not Found The consumer group with the specified ID does not exist.
GROUP_MAX_SIZE_REACHED Group Max Size Reached The consumer group has reached its maximum size. No additional members can join until existing members leave.
GROUP_SUBSCRIBED_TO_TOPIC Group Subscribed to Topic The topic cannot be deleted because one or more consumer groups are currently subscribed to it.
ILLEGAL_GENERATION Illegal Generation The generation ID provided in the request does not match the current generation of the consumer group.
ILLEGAL_SASL_STATE Illegal SASL State The request was made in an invalid state for the SASL handshake, such as sending data before authentication is complete.
INCONSISTENT_CLUSTER_ID Inconsistent Cluster ID The cluster ID in the request does not match the cluster ID of this broker. The client may be connecting to the wrong cluster.
INCONSISTENT_GROUP_PROTOCOL Inconsistent Group Protocol The group member did not use the same protocol type as the rest of the group. All members must use the same protocol.
INCONSISTENT_TOPIC_ID Inconsistent Topic ID The topic ID in the request does not match the topic ID known to this broker for the given topic name.
INCONSISTENT_VOTER_SET Inconsistent Voter Set The voter set in the request is inconsistent with the current voter set known to the broker.
INELIGIBLE_REPLICA Ineligible Replica The replica is not eligible for the requested operation, such as a reassignment, because it does not meet the required conditions.
INVALID_COMMIT_OFFSET_SIZE Invalid Commit Offset Size The offset commit request contained an invalid metadata size. Reduce the size of the commit metadata.
INVALID_CONFIG Invalid Config A configuration value provided in the request is invalid. Check the configuration key and value.
INVALID_FETCH_SESSION_EPOCH Invalid Fetch Session Epoch The epoch provided for the incremental fetch session does not match the broker's current epoch for that session.
INVALID_FETCH_SIZE Invalid Fetch Size The requested fetch size is invalid. The fetch.min.bytes or max.partition.fetch.bytes value is not valid.
INVALID_GROUP_ID Invalid Group ID The group ID is empty or contains invalid characters. Group IDs must be non-empty strings.
INVALID_PARTITIONS Invalid Partitions The number of partitions specified in the topic creation request is invalid. Must be a positive integer.
INVALID_PRINCIPAL_TYPE Invalid Principal Type The principal type specified in the request is not supported or is invalid in this context.
INVALID_PRODUCER_EPOCH Invalid Producer Epoch The producer attempted to write using an epoch that is no longer current. The producer must restart and obtain a new epoch.
INVALID_PRODUCER_ID_MAPPING Invalid Producer ID Mapping The producer ID is not mapped to a valid transaction ID on this broker.
INVALID_RECORD Invalid Record A record in the batch failed validation. Check the record key, value, and headers for invalid content.
INVALID_REGISTRATION Invalid Registration The broker registration request is invalid. Check the registration parameters for correctness.
INVALID_REPLICA_ASSIGNMENT Invalid Replica Assignment The manual replica assignment specified for the topic is invalid or inconsistent.
INVALID_REPLICATION_FACTOR Invalid Replication Factor The replication factor specified in the topic creation request is invalid or exceeds the number of available brokers.
INVALID_REQUEST Invalid Request The request is malformed or contains an invalid combination of parameters.
INVALID_REQUIRED_ACKS Invalid Required Acks The produce request specified an invalid value for the required acks field. Valid values are -1, 0, and 1.
INVALID_SESSION_TIMEOUT Invalid Session Timeout The session timeout provided in the JoinGroup request is not within the allowed range configured on the broker.
INVALID_TIMESTAMP Invalid Timestamp The record contained a timestamp that is out of range or otherwise invalid for the broker's configuration.
INVALID_TOPIC_EXCEPTION Invalid Topic Exception The request specified a topic that is not valid. Topic names must conform to naming rules and must not be empty.
INVALID_TRANSACTION_TIMEOUT Invalid Transaction Timeout The transaction timeout specified in the InitProducerId request exceeds the maximum allowed by the broker.
INVALID_TXN_STATE Invalid Transaction State The transaction is in an invalid state for the requested operation. Check the transaction lifecycle.
INVALID_UPDATE_VERSION Invalid Update Version The update version provided in the request is invalid or does not meet the required constraints.
KAFKA_STORAGE_ERROR Kafka Storage Error An error occurred in the log storage layer. The broker may be experiencing disk or filesystem issues.
LEADER_NOT_AVAILABLE Leader Not Available There is currently no leader for this partition and hence it is unavailable for writes. Clients should retry after refreshing metadata.
LISTENER_NOT_FOUND Listener Not Found The listener name provided in the request was not found on this broker. Check the broker's listener configuration.
LOG_DIR_NOT_FOUND Log Dir Not Found The specified log directory was not found on this broker. Check the broker's log.dirs configuration.
MEMBER_ID_REQUIRED Member ID Required A member ID is required for this group operation but was not provided. The client must first join the group to obtain a member ID.
MESSAGE_TOO_LARGE Message Too Large The request included a message larger than the maximum message size the broker will accept. Reduce the message size or increase the broker's message.max.bytes.
MISMATCHED_ENDPOINT_TYPE Mismatched Endpoint Type The endpoint type in the request does not match the endpoint type of the target broker.
NETWORK_EXCEPTION Network Exception A network exception occurred while the server was processing the request. The client may retry.
NEW_LEADER_ELECTED New Leader Elected A new leader has been elected for this partition. The client should refresh its metadata and retry the request.
NO_REASSIGNMENT_IN_PROGRESS No Reassignment in Progress A cancel reassignment request was issued but there is no ongoing reassignment for this partition.
NON_EMPTY_GROUP Non-Empty Group The consumer group cannot be deleted because it still has active members. Wait for all members to leave before deleting.
NONE None No error. The request completed successfully.
NOT_CONTROLLER Not Controller This broker is not the current controller. The client should find the controller broker and retry.
NOT_COORDINATOR Not Coordinator This broker is not the coordinator for the given group or transaction. The client should look up the correct coordinator.
NOT_ENOUGH_REPLICAS Not Enough Replicas The number of in-sync replicas is below the minimum required to satisfy the produce request's acks setting.
NOT_ENOUGH_REPLICAS_AFTER_APPEND Not Enough Replicas After Append The message was written to the log but the required number of in-sync replicas did not acknowledge it in time.
NOT_LEADER_OR_FOLLOWER Not Leader or Follower The broker is not the leader or follower for the requested topic partition. Clients should refresh their metadata and retry.
OFFSET_METADATA_TOO_LARGE Offset Metadata Too Large The committed offset metadata is too large. Reduce the size of the metadata string.
OFFSET_MOVED_TO_TIERED_STORAGE Offset Moved to Tiered Storage The requested offset resides in tiered storage and is not immediately available from the local log.
OFFSET_NOT_AVAILABLE Offset Not Available The offset is not yet available because the preferred read replica is not fully caught up. Retry after a short delay.
OFFSET_OUT_OF_RANGE Offset Out of Range The requested offset is outside the range of offsets maintained by the server for the given topic partition.
OPERATION_NOT_ATTEMPTED Operation Not Attempted The operation was not attempted because a previous operation in the batch failed. Retry after addressing the earlier failure.
OUT_OF_ORDER_SEQUENCE_NUMBER Out of Order Sequence Number The idempotent producer sent a record batch with a sequence number out of order. This indicates a client bug.
POLICY_VIOLATION Policy Violation The request violated a policy configured on the broker, such as a topic naming policy or quota policy.
POSITION_OUT_OF_RANGE Position Out of Range The requested position is out of range for the snapshot. The position must be within the bounds of an existing snapshot.
PREFERRED_LEADER_NOT_AVAILABLE Preferred Leader Not Available The preferred leader for this partition is not available. A less-preferred replica is serving as leader.
PRINCIPAL_DESERIALIZATION_FAILURE Principal Deserialization Failure The broker failed to deserialise the principal from the request. The principal data may be malformed or of an unknown type.
PRODUCER_FENCED Producer Fenced The producer has been fenced by a newer producer with the same transactional ID. The old producer must stop sending records.
REASSIGNMENT_IN_PROGRESS Reassignment in Progress A partition reassignment is already in progress for this topic. Wait for the current reassignment to complete.
REBALANCE_IN_PROGRESS Rebalance in Progress The group is currently undergoing a rebalance. The consumer should rejoin the group.
RECORD_LIST_TOO_LARGE Record List Too Large The record batch in the request exceeds the maximum configured batch size for the broker.
REPLICA_NOT_AVAILABLE Replica Not Available The replica is not available for the requested topic partition. The replica may not yet have caught up to the leader.
REQUEST_TIMED_OUT Request Timed Out The request exceeded the configured timeout. The client may retry the request.
RESOURCE_NOT_FOUND Resource Not Found The requested resource does not exist. Check the resource name and type.
SASL_AUTHENTICATION_FAILED SASL Authentication Failed SASL authentication failed. The client provided incorrect credentials or an unsupported authentication method.
SECURITY_DISABLED Security Disabled Security features are not enabled on this broker. The requested security operation cannot be performed.
SNAPSHOT_NOT_FOUND Snapshot Not Found The requested snapshot does not exist on this broker.
STALE_BROKER_EPOCH Stale Broker Epoch The broker epoch in the request is stale. The broker has been restarted and assigned a new epoch.
STALE_CONTROLLER_EPOCH Stale Controller Epoch The controller epoch is stale. A new controller has been elected since this request was issued.
STALE_MEMBER_EPOCH Stale Member Epoch The member epoch in the request is older than the current epoch known to the coordinator. The member should use the latest epoch.
TELEMETRY_TOO_LARGE Telemetry Too Large The telemetry data submitted by the client exceeds the maximum allowed size.
THROTTLING_QUOTA_EXCEEDED Throttling Quota Exceeded The client has exceeded its quota and the request has been throttled. Reduce the request rate.
TOPIC_ALREADY_EXISTS Topic Already Exists A topic with the given name already exists. Use a different name or check whether the topic was intentionally pre-created.
TOPIC_AUTHORIZATION_FAILED Topic Authorization Failed The client is not authorised to perform the requested operation on the given topic.
TOPIC_DELETION_DISABLED Topic Deletion Disabled Topic deletion is disabled on this cluster. Enable delete.topic.enable to allow topic deletion.
TRANSACTION_ABORTABLE Transaction Abortable The transaction encountered an error but can be aborted. The producer should abort and restart the transaction.
TRANSACTION_COORDINATOR_FENCED Transaction Coordinator Fenced The transaction coordinator has been fenced due to a new producer epoch or a coordinator reload. The producer must reinitialise.
TRANSACTIONAL_ID_AUTHORIZATION_FAILED Transactional ID Authorization Failed The client is not authorised to use the specified transactional ID.
TRANSACTIONAL_ID_NOT_FOUND Transactional ID Not Found The transactional ID specified in the request was not found. The producer may need to reinitialise.
UNACCEPTABLE_CREDENTIAL Unacceptable Credential The credential provided in the request is not acceptable. It may be malformed or of an unsupported type.
UNKNOWN_CONTROLLER_ID Unknown Controller ID The controller ID specified in the request is not known to this broker.
UNKNOWN_LEADER_EPOCH Unknown Leader Epoch The leader epoch in the request is larger than the current leader epoch. The leader has not yet reached this epoch.
UNKNOWN_MEMBER_ID Unknown Member ID The member ID is not recognised as a member of the group. The consumer may need to rejoin the group.
UNKNOWN_PRODUCER_ID Unknown Producer ID The producer ID is not known to the broker. The producer should reinitialise with a new producer ID and epoch.
UNKNOWN_SERVER_ERROR Unknown Server Error An unexpected server error occurred. This is a catch-all for errors that do not have a specific error code.
UNKNOWN_SUBSCRIPTION_ID Unknown Subscription ID The subscription ID provided in the request does not correspond to a known subscription.
UNKNOWN_TOPIC_ID Unknown Topic ID The topic ID specified in the request is not known to this broker. The topic may have been deleted or the client has stale metadata.
UNKNOWN_TOPIC_OR_PARTITION Unknown Topic or Partition The requested topic or partition does not exist on this broker. Clients should refresh their metadata.
UNRELEASED_INSTANCE_ID Unreleased Instance ID The static member instance ID is still in use. The previous session for this instance ID has not yet been released.
UNSTABLE_OFFSET_COMMIT Unstable Offset Commit There is an unstable offset commit for this partition, typically due to an ongoing transaction. Wait for the transaction to complete or abort.
UNSUPPORTED_ASSIGNOR Unsupported Assignor The partition assignor specified by the consumer is not supported by the group coordinator.
UNSUPPORTED_COMPRESSION_TYPE Unsupported Compression Type The compression type specified in the record batch is not supported by this broker version.
UNSUPPORTED_ENDPOINT_TYPE Unsupported Endpoint Type The endpoint type specified in the request is not supported by this broker.
UNSUPPORTED_FOR_MESSAGE_FORMAT Unsupported for Message Format The requested operation is not supported for the message format version in use on this topic.
UNSUPPORTED_SASL_MECHANISM Unsupported SASL Mechanism The SASL mechanism requested by the client is not supported or enabled on the broker.
UNSUPPORTED_VERSION Unsupported Version The version of the request API is not supported by this broker. The client should use a lower API version.