Class RetriableException

java.lang.Object
java.lang.Throwable
java.lang.Exception
java.lang.RuntimeException
org.apache.kafka.common.KafkaException
org.apache.kafka.common.errors.ApiException
org.apache.kafka.common.errors.RetriableException
All Implemented Interfaces:
Serializable
Direct Known Subclasses:
AuthorizerNotReadyException, ConcurrentTransactionsException, CoordinatorLoadInProgressException, CorruptRecordException, DisconnectException, FetchSessionIdNotFoundException, FetchSessionTopicIdException, InvalidFetchSessionEpochException, InvalidShareSessionEpochException, MetadataNotAvailableException, NotControllerException, NotEnoughReplicasAfterAppendException, NotEnoughReplicasException, OffsetNotAvailableException, RefreshRetriableException, RetriableCommitFailedException, ShareSessionLimitReachedException, ShareSessionNotFoundException, ThrottlingQuotaExceededException, TimeoutException, UnknownLeaderEpochException, UnstableOffsetCommitException
public abstract class RetriableExceptionextends ApiException
A retriable exception is a transient exception that if retried may succeed.
See Also:

  • Constructor Details

    • RetriableException

      public RetriableException(String message, Throwable cause)

    • RetriableException

      public RetriableException(String message)

    • RetriableException

      public RetriableException(Throwable cause)

    • RetriableException

      public RetriableException()