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:
  • Constructor Details

    • TaskMigratedException

      public TaskMigratedException(String message)
    • TaskMigratedException

      public TaskMigratedException(String message, Throwable throwable)