Package org.apache.kafka.clients.consumer

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 CommitFailedExceptionextends KafkaException
This exception is raised when an offset commit with KafkaConsumer.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:

  • Constructor Details

    • CommitFailedException

      public CommitFailedException(String message)

    • CommitFailedException

      public CommitFailedException()