Package org.apache.kafka.common.errors

Class ApplicationRecoverableException

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.ApplicationRecoverableException

All Implemented Interfaces:

Serializable

Direct Known Subclasses:

FencedInstanceIdException, IllegalGenerationException, InvalidPidMappingException, InvalidProducerEpochException, ProducerFencedException, UnknownMemberIdException

public abstract class ApplicationRecoverableException
extends ApiException

Indicates that the error is fatal to the producer, and the application needs to restart the producer after handling the error. Depending on the application, different recovery strategies (e.g., re-balancing task, restoring from checkpoints) may be employed.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
ApplicationRecoverableException()
ApplicationRecoverableException(String message)
ApplicationRecoverableException(String message, Throwable cause)
ApplicationRecoverableException(Throwable cause)

Method Summary

Methods inherited from class org.apache.kafka.common.errors.ApiException

fillInStackTrace

Methods inherited from class java.lang.Throwable

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

Methods inherited from class java.lang.Object

equals, getClass, hashCode, notify, notifyAll, wait, wait, wait

Constructor Details

ApplicationRecoverableException

public ApplicationRecoverableException(String message,
 Throwable cause)

ApplicationRecoverableException

public ApplicationRecoverableException(String message)

ApplicationRecoverableException

public ApplicationRecoverableException(Throwable cause)

ApplicationRecoverableException

public ApplicationRecoverableException()