RetriableException is a subclass of KafkaException, indicating transient issues thatmight succeed if retried. Examples include:
LeaderNotAvailableException: Happens when metadata is not yet propagated or leader election is in progress.
NotEnoughReplicasException: Happens when the number of in-sync replicas is insufficient. This can be transient if replicas come back online.
From theApache Kafka Java Client documentation:
"These exceptions (like LeaderNotAvailableException, NotEnoughReplicasException) are transient and the client will retry them automatically depending on retry configuration."
RecordTooLargeExceptionandAuthorizationExceptionarenon-retriableas they indicate client-side or permission errors.
[Reference:Apache Kafka Java Client API > org.apache.kafka.common.errors, ============]
Contribute your Thoughts:
Chosen Answer:
This is a voting comment (?). You can switch to a simple comment. It is better to Upvote an existing comment if you don't have anything to add.
Submit