org.apache.kafka.streams.errors

Class TaskMigratedException

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.TaskMigratedException

All Implemented Interfaces:

java.io.Serializable

public class TaskMigratedException
extends StreamsException

Indicates that a task got migrated to another thread. Thus, the task raising this exception can be cleaned up and closed as "zombie".

See Also:

Serialized Form

Constructor Summary

Constructors

Constructor and Description
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, org.apache.kafka.common.TopicPartition topicPartition, long endOffset, long pos)

Method Summary

Methods

Modifier and Type	Method and Description
org.apache.kafka.streams.processor.internals.Task	migratedTask()

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

TaskMigratedException

public TaskMigratedException(org.apache.kafka.streams.processor.internals.Task task)

TaskMigratedException

public TaskMigratedException(org.apache.kafka.streams.processor.internals.Task task,
                     org.apache.kafka.common.TopicPartition topicPartition,
                     long endOffset,
                     long pos)

TaskMigratedException

public TaskMigratedException(org.apache.kafka.streams.processor.internals.Task task,
                     java.lang.Throwable throwable)

Method Detail

migratedTask

public org.apache.kafka.streams.processor.internals.Task migratedTask()