Class TaskCorruptedException

  • All Implemented Interfaces:
    java.io.Serializable

    public class TaskCorruptedException
    extends StreamsException
    Indicates a specific task is corrupted and need to be re-initialized. It can be thrown when 1) Under EOS, if the checkpoint file does not contain offsets for corresponding store's changelogs, meaning previously it was not close cleanly; 2) Out-of-range exception thrown during restoration, meaning that the changelog has been modified and we re-bootstrap the store.
    See Also:
    Serialized Form
    • Constructor Summary

      Constructors 
      Constructor Description
      TaskCorruptedException​(java.util.Map<TaskId,​java.util.Collection<org.apache.kafka.common.TopicPartition>> taskWithChangelogs)  
      TaskCorruptedException​(java.util.Map<TaskId,​java.util.Collection<org.apache.kafka.common.TopicPartition>> taskWithChangelogs, org.apache.kafka.clients.consumer.InvalidOffsetException e)  
    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      java.util.Map<TaskId,​java.util.Collection<org.apache.kafka.common.TopicPartition>> corruptedTaskWithChangelogs()  
      • Methods inherited from class java.lang.Throwable

        addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, wait, wait, wait
    • Constructor Detail

      • TaskCorruptedException

        public TaskCorruptedException​(java.util.Map<TaskId,​java.util.Collection<org.apache.kafka.common.TopicPartition>> taskWithChangelogs)
      • TaskCorruptedException

        public TaskCorruptedException​(java.util.Map<TaskId,​java.util.Collection<org.apache.kafka.common.TopicPartition>> taskWithChangelogs,
                                      org.apache.kafka.clients.consumer.InvalidOffsetException e)
    • Method Detail

      • corruptedTaskWithChangelogs

        public java.util.Map<TaskId,​java.util.Collection<org.apache.kafka.common.TopicPartition>> corruptedTaskWithChangelogs()