org.apache.kafka.common.errors
Exceptions
ApiException
AuthenticationException
AuthenticationTimeoutException
AuthorizationException
AuthorizerNotReadyException
BalanceCannotBeImprovedException
BalancerBrokerExcludedForReplicaPlacementException
BalancerJbodEnabledMisconfigurationException
BalancerLoadError
BalancerMisconfigurationException
BalancerOfflineException
BalancerOperationFailedException
BrokerAdditionInProgressException
BrokerFailureFixInProgressException
BrokerIdNotRegisteredException
BrokerNotAvailableException
BrokerRegistrationDoesNotContainActiveSecretException
BrokerRemovalCanceledException
BrokerRemovalInProgressException
BrokerRemovedException
BrokerReplicaExclusionNotFoundException
CellNotFoundException
ClusterAuthorizationException
ClusterLinkDisabledException
ClusterLinkExistsException
ClusterLinkInUseException
ClusterLinkNotFoundException
ClusterLinkPausedException
ConcurrentTransactionsException
ControllerMovedException
ControllerRegistrationDoesNotContainActiveSecretException
CoordinatorLoadInProgressException
CoordinatorNotAvailableException
CorruptRecordException
DelegationTokenAuthorizationException
DelegationTokenDisabledException
DelegationTokenExpiredException
DelegationTokenNotFoundException
DelegationTokenOwnerMismatchException
DemotionLimitReachedException
DisconnectException
DuplicateBrokerRegistrationException
DuplicateResourceException
DuplicateSequenceException
ElectionNotNeededException
EligibleLeadersNotAvailableException
EvenClusterLoadTaskInProgressException
FeatureUpdateFailedException
FencedInstanceIdException
FencedLeaderEpochException
FencedMemberEpochException
FencedReplicationSessionIdException
FetchSessionIdNotFoundException
FetchSessionTopicIdException
GroupAuthorizationException
GroupIdNotFoundException
GroupMaxSizeReachedException
GroupNotEmptyException
GroupSubscribedToTopicException
IllegalGenerationException
IllegalSaslStateException
InconsistentClusterIdException
InconsistentGroupProtocolException
InconsistentTopicIdException
InconsistentVoterSetException
IneligibleReplicaException
InsufficientDataForCellLoadComputationException
InsufficientRebalancePlanMetricsException
InterruptException
InvalidBrokerRemovalException
InvalidBrokerReplicaExclusionException
InvalidClusterLinkException
InvalidCommitOffsetSizeException
InvalidConfigurationException
InvalidFetchSessionEpochException
InvalidFetchSizeException
InvalidGroupIdException
InvalidMetadataException
InvalidOffsetException
InvalidPartitionsException
InvalidPidMappingException
InvalidPrincipalTypeException
InvalidProducerEpochException
InvalidRegistrationException
InvalidReplicaAssignmentException
InvalidReplicationFactorException
InvalidReplicationOffsetException
InvalidRequestException
InvalidRequiredAcksException
InvalidSessionTimeoutException
InvalidTimestampException
InvalidTopicException
InvalidTxnStateException
InvalidTxnTimeoutException
InvalidUpdateVersionException
KafkaStorageException
LeaderNotAvailableException
ListenerNotFoundException
LogDirNotFoundException
MemberIdRequiredException
MismatchedEndpointTypeException
MultiChecksumTypeException
NetworkException
NewLeaderElectedException
NoReassignmentInProgressException
NotControllerException
NotCoordinatorException
NotEnoughReplicasAfterAppendException
NotEnoughReplicasException
NotLeaderForPartitionException
NotLeaderOrFollowerException
OffsetMetadataTooLarge
OffsetMovedToTieredStorageException
OffsetNotAvailableException
OffsetOutOfRangeException
OffsetTieredException
OperationNotAttemptedException
OtherChecksumTypeException
OutOfOrderSequenceException
PolicyViolationException
PositionOutOfRangeException
PreferredLeaderNotAvailableException
PrincipalDeserializationException
ProducerFencedException
PushReplicationStartedException
QuotaEntityNotFoundException
ReassignmentInProgressException
RebalanceInProgressDuringPlanComputationException
RebalanceInProgressException
RebalancePlanComputationException
RecordBatchTooLargeException
RecordDeserializationException
RecordTooLargeException
ReplicaNotAvailableException
ResourceNotFoundException
RetriableException
SaslAuthenticationException
SecretsLogFailedException
SecurityDisabledException
SerializationException
SnapshotNotFoundException
SslAuthenticationException
StaleBrokerEpochException
StaleMemberEpochException
TelemetryTooLargeException
TenantNotFoundException
ThrottlingQuotaExceededException
TimeoutException
TopicAuthorizationException
TopicDeletionDisabledException
TopicExistsException
TransactionAbortedException
TransactionalIdAuthorizationException
TransactionalIdNotFoundException
TransactionCoordinatorFencedException
UnacceptableCredentialException
UnknownControllerIdException
UnknownLeaderEpochException
UnknownMemberIdException
UnknownProducerIdException
UnknownServerException
UnknownSubscriptionIdException
UnknownTopicIdException
UnknownTopicOrPartitionException
UnreleasedInstanceIdException
UnrepresentableBrokerIdException
UnstableOffsetCommitException
UnsupportedAssignorException
UnsupportedByAuthenticationException
UnsupportedCompressionTypeException
UnsupportedEndpointTypeException
UnsupportedForMessageFormatException
UnsupportedSaslMechanismException
UnsupportedVersionException
WakeupException