Class TaskCorruptedException

java.lang.Object
java.lang.Throwable
java.lang.Exception
java.lang.RuntimeException
org.apache.kafka.common.KafkaException
org.apache.kafka.streams.errors.StreamsException
org.apache.kafka.streams.errors.TaskCorruptedException
All Implemented Interfaces:
Serializable
public class TaskCorruptedExceptionextends StreamsException
Indicates a specific task is corrupted and need to be re-initialized. It can be thrown when:
  • Under EOS, if the checkpoint file does not contain offsets for corresponding store's changelogs, meaning previously it was not close cleanly.
  • Out-of-range exception thrown during restoration, meaning that the changelog has been modified and we re-bootstrap the store.
See Also:

  • Constructor Details

    • TaskCorruptedException

      public TaskCorruptedException(Set<TaskId> corruptedTasks)

    • TaskCorruptedException

      public TaskCorruptedException(Set<TaskId> corruptedTasks, org.apache.kafka.clients.consumer.InvalidOffsetException e)

  • Method Details

    • corruptedTasks

      public Set<TaskId> corruptedTasks()