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