Class 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 Detail

      • TaskMigratedException

        public TaskMigratedException​(String message)
      • TaskMigratedException

        public TaskMigratedException​(String message,
                                     Throwable throwable)