Package org.apache.kafka.common.errors
Provides common exception classes.
-
Exception Summary Exception Description ApiException Any API exception that is part of the public protocol and should be a subclass of this class and be part of this package.AuthenticationException This exception indicates that SASL authentication has failed.AuthorizationException AuthorizerNotReadyException An exception that indicates that the authorizer is not ready to receive the request yet.BrokerIdNotRegisteredException BrokerNotAvailableException ClusterAuthorizationException ConcurrentTransactionsException ControllerMovedException CoordinatorLoadInProgressException In the context of the group coordinator, the broker returns this error code for any coordinator request if it is still loading the group metadata (e.g.CoordinatorNotAvailableException In the context of the group coordinator, the broker returns this error code for metadata or offset commit requests if the group metadata topic has not been created yet.CorruptRecordException This exception indicates a record has failed its internal CRC check, this generally indicates network or disk corruption.DelegationTokenAuthorizationException DelegationTokenDisabledException DelegationTokenExpiredException DelegationTokenNotFoundException DelegationTokenOwnerMismatchException DisconnectException Server disconnected before a request could be completed.DuplicateBrokerRegistrationException DuplicateResourceException Exception thrown due to a request that illegally refers to the same resource twice (for example, trying to both create and delete the same SCRAM credential for a particular user in a single request).DuplicateSequenceException ElectionNotNeededException EligibleLeadersNotAvailableException FeatureUpdateFailedException FencedInstanceIdException FencedLeaderEpochException The request contained a leader epoch which is smaller than that on the broker that received the request.FencedMemberEpochException FetchSessionIdNotFoundException FetchSessionTopicIdException GroupAuthorizationException GroupIdNotFoundException GroupMaxSizeReachedException Indicates that a consumer group is already at its configured maximum capacity and cannot accommodate more membersGroupNotEmptyException GroupSubscribedToTopicException IllegalGenerationException IllegalSaslStateException This exception indicates unexpected requests prior to SASL authentication.InconsistentClusterIdException InconsistentGroupProtocolException InconsistentTopicIdException InconsistentVoterSetException IneligibleReplicaException InterruptException An unchecked wrapper for InterruptedExceptionInvalidCommitOffsetSizeException InvalidConfigurationException InvalidFetchSessionEpochException InvalidFetchSizeException InvalidGroupIdException InvalidMetadataException An exception that may indicate the client's metadata is out of dateInvalidOffsetException Thrown when the offset for a set of partitions is invalid (either undefined or out of range), and no reset policy has been configured.InvalidPartitionsException InvalidPidMappingException InvalidPrincipalTypeException InvalidProducerEpochException This exception indicates that the produce request sent to the partition leader contains a non-matching producer epoch.InvalidReplicaAssignmentException InvalidReplicationFactorException InvalidRequestException Thrown when a request breaks basic wire protocol rules.InvalidRequiredAcksException InvalidSessionTimeoutException InvalidTimestampException Indicate the timestamp of a record is invalid.InvalidTopicException The client has attempted to perform an operation on an invalid topic.InvalidTxnStateException InvalidTxnTimeoutException The transaction coordinator returns this error code if the timeout received via the InitProducerIdRequest is larger than the `transaction.max.timeout.ms` config value.InvalidUpdateVersionException KafkaStorageException Miscellaneous disk-related IOException occurred when handling a request.LeaderNotAvailableException There is no currently available leader for the given partition (either because a leadership election is in progress or because all replicas are down).ListenerNotFoundException The leader does not have an endpoint corresponding to the listener on which metadata was requested.LogDirNotFoundException Thrown when a request is made for a log directory that is not present on the brokerMemberIdRequiredException NetworkException A misc.NewLeaderElectedException NoReassignmentInProgressException Thrown if a reassignment cannot be cancelled because none is in progress.NotControllerException NotCoordinatorException In the context of the group coordinator, the broker returns this error code if it receives an offset fetch or commit request for a group it's not the coordinator of.NotEnoughReplicasAfterAppendException Number of insync replicas for the partition is lower than min.insync.replicas This exception is raised when the low ISR size is discovered *after* the message was already appended to the log.NotEnoughReplicasException Number of insync replicas for the partition is lower than min.insync.replicasNotLeaderForPartitionException Deprecated. since 2.6.NotLeaderOrFollowerException Broker returns this error if a request could not be processed because the broker is not the leader or follower for a topic partition.OffsetMetadataTooLarge The client has tried to save its offset with associated metadata larger than the maximum size allowed by the server.OffsetMovedToTieredStorageException OffsetNotAvailableException Indicates that the leader is not able to guarantee monotonically increasing offsets due to the high watermark lagging behind the epoch start offset after a recent leader electionOffsetOutOfRangeException No reset policy has been defined, and the offsets for these partitions are either larger or smaller than the range of offsets the server has for the given partition.OperationNotAttemptedException Indicates that the broker did not attempt to execute this operation.OutOfOrderSequenceException This exception indicates that the broker received an unexpected sequence number from the producer, which means that data may have been lost.PolicyViolationException Exception thrown if a create topics request does not satisfy the configured policy for a topic.PositionOutOfRangeException PreferredLeaderNotAvailableException PrincipalDeserializationException Exception used to indicate a kafka principal deserialization failure during request forwarding.ProducerFencedException This fatal exception indicates that another producer with the sametransactional.idhas been started.ReassignmentInProgressException Thrown if a request cannot be completed because a partition reassignment is in progress.RebalanceInProgressException RecordBatchTooLargeException This record batch is larger than the maximum allowable sizeRecordDeserializationException This exception is raised for any error that occurs while deserializing records received by the consumer using the configuredDeserializer.RecordTooLargeException This record is larger than the maximum allowable sizeReplicaNotAvailableException The replica is not available for the requested topic partition.ResourceNotFoundException Exception thrown due to a request for a resource that does not exist.RetriableException A retriable exception is a transient exception that if retried may succeed.SaslAuthenticationException This exception indicates that SASL authentication has failed.SecurityDisabledException An error indicating that security is disabled on the broker.SerializationException Any exception during serialization in the producerSnapshotNotFoundException SslAuthenticationException This exception indicates that SSL handshake has failed.StaleBrokerEpochException StaleMemberEpochException The StaleMemberEpochException is used in the context of the new consumer group protocol (KIP-848).ThrottlingQuotaExceededException Exception thrown if an operation on a resource exceeds the throttling quota.TimeoutException Indicates that a request timed out.TopicAuthorizationException TopicDeletionDisabledException TopicExistsException TransactionAbortedException This is the Exception thrown when we are aborting any undrained batches during a transaction which is aborted without any underlying cause - which likely means that the user chose to abort.TransactionalIdAuthorizationException TransactionalIdNotFoundException TransactionCoordinatorFencedException UnacceptableCredentialException Exception thrown when attempting to define a credential that does not meet the criteria for acceptability (for example, attempting to create a SCRAM credential with an empty username or password or too few/many iterations).UnknownLeaderEpochException The request contained a leader epoch which is larger than that on the broker that received the request.UnknownMemberIdException UnknownProducerIdException This exception is raised by the broker if it could not locate the producer metadata associated with the producerId in question.UnknownServerException An error occurred on the server for which the client doesn't have a corresponding error code.UnknownTopicIdException UnknownTopicOrPartitionException This topic/partition doesn't exist.UnreleasedInstanceIdException UnstableOffsetCommitException Exception thrown when there are unstable offsets for the requested topic partitions.UnsupportedAssignorException UnsupportedByAuthenticationException Authentication mechanism does not support the requested function.UnsupportedCompressionTypeException The requesting client does not support the compression type of given partition.UnsupportedForMessageFormatException The message format version does not support the requested function.UnsupportedSaslMechanismException This exception indicates that the SASL mechanism requested by the client is not enabled on the broker.UnsupportedVersionException Indicates that a request API or version needed by the client is not supported by the broker.WakeupException Exception used to indicate preemption of a blocking operation by an external thread.