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 class CommitFailedException extends KafkaException
This exception is raised when an offset commit withKafkaConsumer.commitSync()
fails with an unrecoverable error. This can happen 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()
CommitFailedException(String message)
-
Method Summary
-
Methods inherited from class java.lang.Throwable
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
-
-
-
-
Constructor Detail
-
CommitFailedException
public CommitFailedException(String message)
-
CommitFailedException
public CommitFailedException()
-
-