public class TaskCorruptedException extends StreamsException
Constructor and 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) |
Modifier and Type | Method and Description |
---|---|
java.util.Map<TaskId,java.util.Collection<org.apache.kafka.common.TopicPartition>> |
corruptedTaskWithChangelogs() |
public TaskCorruptedException(java.util.Map<TaskId,java.util.Collection<org.apache.kafka.common.TopicPartition>> taskWithChangelogs)
public TaskCorruptedException(java.util.Map<TaskId,java.util.Collection<org.apache.kafka.common.TopicPartition>> taskWithChangelogs, org.apache.kafka.clients.consumer.InvalidOffsetException e)
public java.util.Map<TaskId,java.util.Collection<org.apache.kafka.common.TopicPartition>> corruptedTaskWithChangelogs()