kafka.common.errors
Class RetryableException

java.lang.Object
  java.lang.Throwable
      java.lang.Exception
          java.lang.RuntimeException
              kafka.common.KafkaException
                  kafka.common.errors.ApiException
                      kafka.common.errors.RetryableException

All Implemented Interfaces:

java.io.Serializable

Direct Known Subclasses:

LeaderNotAvailableException, NotLeaderForPartitionException

public abstract class RetryableException
extends ApiException

A retryable exception is an exception that is safe to retry. To be retryable an exception should be

1. Transient, there is no point retrying a error due to a non-existant topic or message too large
2. Idempotent, the exception is known to not change any state on the server

A client may choose to retry any request they like, but exceptions extending this class are always safe and sane to retry.

See Also:

Serialized Form

Constructor Summary

RetryableException()

RetryableException(java.lang.String message)

RetryableException(java.lang.String message, java.lang.Throwable cause)

RetryableException(java.lang.Throwable cause)

Method Summary

Methods inherited from class kafka.common.errors.ApiException

fillInStackTrace

Methods inherited from class java.lang.Throwable

getCause, getLocalizedMessage, getMessage, getStackTrace, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Detail

RetryableException

public RetryableException(java.lang.String message,
                          java.lang.Throwable cause)

RetryableException

public RetryableException(java.lang.String message)

RetryableException

public RetryableException(java.lang.Throwable cause)

RetryableException

public RetryableException()