| 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 |
|
| 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.
|
| FetchSessionIdNotFoundException |
|
| GroupAuthorizationException |
|
| GroupIdNotFoundException |
|
| GroupMaxSizeReachedException |
Indicates that a consumer group is already at its configured maximum capacity and cannot accommodate more members
|
| GroupNotEmptyException |
|
| GroupSubscribedToTopicException |
|
| IllegalGenerationException |
|
| IllegalSaslStateException |
This exception indicates unexpected requests prior to SASL authentication.
|
| InconsistentClusterIdException |
|
| InconsistentGroupProtocolException |
|
| InconsistentTopicIdException |
|
| InconsistentVoterSetException |
|
| InterruptException |
An unchecked wrapper for InterruptedException
|
| InvalidCommitOffsetSizeException |
|
| InvalidConfigurationException |
|
| InvalidFetchSessionEpochException |
|
| InvalidFetchSizeException |
|
| InvalidGroupIdException |
|
| InvalidMetadataException |
An exception that may indicate the client's metadata is out of date
|
| InvalidOffsetException |
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 broker
|
| MemberIdRequiredException |
|
| NetworkException |
A misc.
|
| 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.replicas
|
| NotLeaderForPartitionException |
Deprecated.
|
| 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.
|
| 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 election
|
| OffsetOutOfRangeException |
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 same transactional.id has 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 size
|
| RecordDeserializationException |
This exception is raised for any error that occurs while deserializing records received by the consumer using
the configured Deserializer. |
| RecordTooLargeException |
This record is larger than the maximum allowable size
|
| ReplicaNotAvailableException |
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 producer
|
| SnapshotNotFoundException |
|
| SslAuthenticationException |
This exception indicates that SSL handshake has failed.
|
| StaleBrokerEpochException |
|
| 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.
|
| UnstableOffsetCommitException |
Exception thrown when there are unstable offsets for the requested topic partitions.
|
| 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.
|