org.apache.kafka.streams.errors

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 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 and Description
TaskCorruptedException(Map<TaskId,Collection<TopicPartition>> taskWithChangelogs)
TaskCorruptedException(Map<TaskId,Collection<TopicPartition>> taskWithChangelogs, InvalidOffsetException e)

Method Summary

Modifier and Type	Method and Description
Map<TaskId,Collection<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(Map<TaskId,Collection<TopicPartition>> taskWithChangelogs)

TaskCorruptedException

public TaskCorruptedException(Map<TaskId,Collection<TopicPartition>> taskWithChangelogs,
                              InvalidOffsetException e)

Method Detail

corruptedTaskWithChangelogs

public Map<TaskId,Collection<TopicPartition>> corruptedTaskWithChangelogs()