Class RetriableCommitFailedException

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

org.apache.kafka.clients.consumer.RetriableCommitFailedException

All Implemented Interfaces:

Serializable

@Public
public class RetriableCommitFailedException
extends RetriableException

Exception thrown when an offset commit fails with a retriable error. This exception is generated on the client side upon receiving retriable error codes from the Group Coordinator in a commit response.

Unlike CommitFailedException, this exception indicates that the commit can be retried. The consumer should attempt to commit the offsets again.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
RetriableCommitFailedException(String message)	Constructs a new RetriableCommitFailedException with the specified detail message.
RetriableCommitFailedException(String message, Throwable t)	Constructs a new RetriableCommitFailedException with the specified detail message and cause.
RetriableCommitFailedException(Throwable t)	Constructs a new RetriableCommitFailedException with the specified cause.

Method Summary

Methods inherited from class ApiException

fillInStackTrace

Methods inherited from class Throwable

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

Methods inherited from class Object

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

Constructor Details

RetriableCommitFailedException

public RetriableCommitFailedException(Throwable t)

Constructs a new RetriableCommitFailedException with the specified cause.

Parameters:

t - The cause of the exception

RetriableCommitFailedException

public RetriableCommitFailedException(String message)

Constructs a new RetriableCommitFailedException with the specified detail message.

Parameters:

message - The detail message

RetriableCommitFailedException

public RetriableCommitFailedException(String message,
 Throwable t)

Constructs a new RetriableCommitFailedException with the specified detail message and cause.

Parameters:

message - The detail message

t - The cause of the exception