Class TaskMigratedException

All Implemented Interfaces:

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 Details

    • TaskMigratedException

      public TaskMigratedException​(String message)
    • TaskMigratedException

      public TaskMigratedException​(String message, Throwable throwable)