Class TaskState

java.lang.Object
org.apache.kafka.connect.health.AbstractState
org.apache.kafka.connect.health.TaskState

public class TaskState
extends AbstractState
Describes the state, IDs, and any errors of a connector task.
  • Constructor Details

    • TaskState

      public TaskState​(int taskId, String state, String workerId, String trace)
      Provides an instance of TaskState.
      Parameters:
      taskId - the id associated with the connector task
      state - the status of the task, may not be null or empty
      workerId - id of the worker the task is associated with, may not be null or empty
      trace - error message if that task had failed or errored out, may be null or empty
  • Method Details