See: Description
| Exception | Description |
|---|---|
| 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 authentication has failed.
|
| AuthorizationException | |
| ConnectionException | |
| CorruptRecordException |
This exception indicates a record has failed its internal CRC check, this generally indicates network or disk corruption.
|
| FeatureNotSupportedException |
If a method/api is not supported then this exception is thrown.
|
| InterruptException |
An unchecked wrapper for InterruptedException
|
| InvalidConfigurationException | |
| InvalidLoginCredentialsException |
This exception indicates that user provided invalid login details.
|
| InvalidMessageIdException |
This exception indicates that client has received invalid message id from server.
|
| InvalidMetadataException |
An exception that may indicate the client's metadata is out of date
|
| InvalidTopicException |
The client has attempted to perform an operation on an invalid topic.
|
| NotLeaderForPartitionException |
This server is not the leader for the given partition
|
| ProducerFencedException |
This fatal exception indicates that another producer with the same
transactional.id has been started. |
| RecordBatchTooLargeException |
This record batch is larger than the maximum allowable size
|
| RecordTooLargeException |
This record is larger than the maximum allowable size
|
| RetriableException |
A retriable exception is a transient exception that if retried may succeed.
|
| SerializationException |
Any exception during serialization in the producer
|
| TimeoutException |
Indicates that a request timed out.
|
| TopicExistsException |