org.apache.kafka.common.errors
Exceptions
ApiException
AuthenticationException
AuthorizationException
BrokerNotAvailableException
ClusterAuthorizationException
ConcurrentTransactionsException
ControllerMovedException
CoordinatorLoadInProgressException
CoordinatorNotAvailableException
CorruptRecordException
DisconnectException
DuplicateSequenceException
GroupAuthorizationException
GroupCoordinatorNotAvailableException
GroupLoadInProgressException
IllegalGenerationException
IllegalSaslStateException
InconsistentGroupProtocolException
InterruptException
InvalidCommitOffsetSizeException
InvalidConfigurationException
InvalidFetchSizeException
InvalidGroupIdException
InvalidMetadataException
InvalidOffsetException
InvalidPartitionsException
InvalidPidMappingException
InvalidReplicaAssignmentException
InvalidReplicationFactorException
InvalidRequestException
InvalidRequiredAcksException
InvalidSessionTimeoutException
InvalidTimestampException
InvalidTopicException
InvalidTxnStateException
InvalidTxnTimeoutException
KafkaStorageException
LeaderNotAvailableException
LogDirNotFoundException
NetworkException
NotControllerException
NotCoordinatorException
NotCoordinatorForGroupException
NotEnoughReplicasAfterAppendException
NotEnoughReplicasException
NotLeaderForPartitionException
OffsetMetadataTooLarge
OffsetOutOfRangeException
OperationNotAttemptedException
OutOfOrderSequenceException
PolicyViolationException
ProducerFencedException
ReassignmentInProgressException
RebalanceInProgressException
RecordBatchTooLargeException
RecordTooLargeException
ReplicaNotAvailableException
RetriableException
SaslAuthenticationException
SecurityDisabledException
SerializationException
SslAuthenticationException
TimeoutException
TopicAuthorizationException
TopicExistsException
TransactionalIdAuthorizationException
TransactionCoordinatorFencedException
UnknownMemberIdException
UnknownProducerIdException
UnknownServerException
UnknownTopicOrPartitionException
UnsupportedForMessageFormatException
UnsupportedSaslMechanismException
UnsupportedVersionException
WakeupException