Any API exception that is part of the public protocol and should be a subclass of this class and be part of this package.
This exception indicates a record has failed its internal CRC check, this generally indicates network or disk corruption.
Server disconnected before a request could be completed.
The broker returns this error code for consumer metadata requests or offset commit requests if the offsets topic has not yet been created.
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.
An unchecked wrapper for InterruptedException
An exception that may indicate the client's metadata is out of date
The client has attempted to perform an operation on an invalid topic.
There is no currently available leader for the given partition (either because a leadership election is in progress or because all replicas are down).
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.
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.
Number of insync replicas for the partition is lower than min.insync.replicas
This server is not the leader for the given partition
The client has tried to save its offset with associated metadata larger than the maximum size allowed by the server.
This record batch is larger than the maximum allowable size
This record is larger than the maximum allowable size
A retryable exception is a transient exception that if retried may succeed.
Any exception during serialization in the producer
Indicates that a request timed out.
An error occurred on the server for which the client doesn't have a corresponding error code.
This topic/partition doesn't exist
Exception used to indicate preemption of a blocking operation by an external thread.