Package 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:
Serializable
public class TaskMigratedException extends StreamsException
Indicates that all tasks belongs to the thread have migrated to another thread. This exception can be thrown when the thread gets fenced (either by the consumer coordinator or by the transaction coordinator), which means it is no longer part of the group but a "zombie" already- See Also:
- Serialized Form
-
-
Constructor Summary
Constructors Constructor Description TaskMigratedException(String message)
TaskMigratedException(String message, Throwable throwable)
-
Method Summary
-
Methods inherited from class java.lang.Throwable
addSuppressed, fillInStackTrace, getCause, getLocalizedMessage, getMessage, getStackTrace, getSuppressed, initCause, printStackTrace, printStackTrace, printStackTrace, setStackTrace, toString
-
-