Name | Description | Type | Package | Framework |
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). | Class | org.apache.kafka.common.errors | Apache Kafka |
InvalidTopicException | The client has attempted to perform an operation on an invalid topic. | Class | org.apache.kafka.common.errors | Apache Kafka |
InvalidRequiredAcksException | Class | org.apache.kafka.common.errors | Apache Kafka | |
InvalidMetadataException | An exception that may indicate the client's metadata is out of dateSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
InterruptException | An unchecked wrapper for InterruptedExceptionSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
IllegalGenerationException | Class | org.apache.kafka.common.errors | Apache Kafka | |
GroupLoadInProgressException | The broker returns this error code for any coordiantor request if it is still loading the metadata (after a leader change for that offsets topic partition) for this group. | Class | org.apache.kafka.common.errors | Apache Kafka |
GroupCoordinatorNotAvailableException | The broker returns this error code for consumer metadata requests or offset commit requests if the offsets topic has not yet been created. | Class | org.apache.kafka.common.errors | Apache Kafka |
GroupAuthorizationException | Class | org.apache.kafka.common.errors | Apache Kafka | |
DisconnectException | Server disconnected before a request could be completed. | Class | org.apache.kafka.common.errors | Apache Kafka |
CorruptRecordException | This exception indicates a record has failed its internal CRC check, this generally indicates network or diskSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
ControllerMovedException | Class | org.apache.kafka.common.errors | Apache Kafka | |
BrokerNotAvailableException | Class | org.apache.kafka.common.errors | Apache Kafka | |
ApiException | Any API exception that is part of the public protocol and should be a subclass of this class and be part of thisSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
AuthorizationException | Class | org.apache.kafka.common.errors | Apache Kafka | |
NetworkException | A misc. | Class | org.apache.kafka.common.errors | Apache Kafka |
NotCoordinatorForGroupException | The broker returns this error code if it receives an offset fetch or commit request for a consumer group that it is not a coordinator for. | Class | org.apache.kafka.common.errors | Apache Kafka |
NotEnoughReplicasAfterAppendException | Number of insync replicas for the partition is lower than min. | Class | org.apache.kafka.common.errors | Apache Kafka |
NotEnoughReplicasException | Number of insync replicas for the partition is lower than min. | Class | org.apache.kafka.common.errors | Apache Kafka |
NotLeaderForPartitionException | This server is not the leader for the given partitionSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
OffsetMetadataTooLarge | The client has tried to save its offset with associated metadata larger than the maximum size allowed by the server. | Class | org.apache.kafka.common.errors | Apache Kafka |
RebalanceInProgressException | Class | org.apache.kafka.common.errors | Apache Kafka | |
RecordBatchTooLargeException | This record batch is larger than the maximum allowable sizeSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
RecordTooLargeException | This record is larger than the maximum allowable sizeSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
RetriableException | A retryable exception is a transient exception that if retried may succeed. | Class | org.apache.kafka.common.errors | Apache Kafka |
SerializationException | Any exception during serialization in the producerSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
TimeoutException | Indicates that a request timed out. | Class | org.apache.kafka.common.errors | Apache Kafka |
TopicAuthorizationException | Class | org.apache.kafka.common.errors | Apache Kafka | |
UnknownMemberIdException | Class | org.apache.kafka.common.errors | Apache Kafka | |
UnknownServerException | An error occurred on the server for which the client doesn't have a corresponding error code. | Class | org.apache.kafka.common.errors | Apache Kafka |
UnknownTopicOrPartitionException | This topic/partition doesn't existSee Also:Serialized Form | Class | org.apache.kafka.common.errors | Apache Kafka |
WakeupException | Exception used to indicate preemption of a blocking operation by an external thread. | Class | org.apache.kafka.common.errors | Apache Kafka |