public class TaskMigratedException extends StreamsException
Constructor and Description |
---|
TaskMigratedException() |
TaskMigratedException(Task task) |
TaskMigratedException(Task task,
java.lang.Throwable throwable) |
TaskMigratedException(Task task,
org.apache.kafka.common.TopicPartition topicPartition,
long endOffset,
long pos) |
Modifier and Type | Method and Description |
---|---|
Task |
migratedTask() |
public TaskMigratedException()
public TaskMigratedException(Task task, org.apache.kafka.common.TopicPartition topicPartition, long endOffset, long pos)
public TaskMigratedException(Task task)
public TaskMigratedException(Task task, java.lang.Throwable throwable)
public Task migratedTask()