Package 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:
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()
-
-
-
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()
-
-