Class TaskMigratedException

  • All Implemented Interfaces:
    java.io.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
    • Method Summary

      • 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​(java.lang.String message)
      • TaskMigratedException

        public TaskMigratedException​(java.lang.String message,
                                     java.lang.Throwable throwable)