TaskCorruptedException (kafka 2.8.1 API)

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 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(Set<TaskId> corruptedTasks)`
`TaskCorruptedException(Set<TaskId> corruptedTasks, InvalidOffsetException e)`

Method Summary

All Methods Instance Methods Concrete Methods
Modifier and Type Method Description

Set<TaskId> corruptedTasks()
- 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(Set<TaskId> corruptedTasks)

TaskCorruptedException

public TaskCorruptedException(Set<TaskId> corruptedTasks,
                              InvalidOffsetException e)

Method Detail
- corruptedTasks
```
public Set<TaskId> corruptedTasks()
```