Class CommitFailedException

java.lang.Object

java.lang.Throwable

java.lang.Exception

java.lang.RuntimeException

org.apache.kafka.common.KafkaException

org.apache.kafka.clients.consumer.CommitFailedException

All Implemented Interfaces:

Serializable

@Public
public class CommitFailedException
extends KafkaException

This exception is raised when an offset commit with KafkaConsumer.commitSync() fails with an unrecoverable error. This exception is generated on the client side, typically when a group rebalance completes before the commit could be successfully applied. In this case, the commit cannot generally be retried because some of the partitions may have already been assigned to another member in the group.

See Also:

• Serialized Form

Constructor Summary

Constructors

Constructor	Description
CommitFailedException()	Constructs a new CommitFailedException with a default message explaining the cause of the commit failure.
CommitFailedException(String message)	Constructs a new CommitFailedException with the specified detail message.

Method Summary

Methods inherited from class Throwable

addSuppressed, fillInStackTrace, 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

CommitFailedException

public CommitFailedException(String message)

Constructs a new CommitFailedException with the specified detail message.

Parameters:

message - The error message

CommitFailedException

public CommitFailedException()

Constructs a new CommitFailedException with a default message explaining the cause of the commit failure.