Package org.apache.kafka.connect.health
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.
-
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description boolean
equals(Object o)
int
hashCode()
int
taskId()
Provides the ID of the task.String
toString()
-
Methods inherited from class org.apache.kafka.connect.health.AbstractState
state, traceMessage, workerId
-
-
-
-
Constructor Detail
-
TaskState
public TaskState(int taskId, String state, String workerId, String trace)
Provides an instance ofTaskState
.- Parameters:
taskId
- the id associated with the connector taskstate
- the status of the task, may not benull
or emptyworkerId
- id of the worker the task is associated with, may not benull
or emptytrace
- error message if that task had failed or errored out, may benull
or empty
-
-
Method Detail
-
taskId
public int taskId()
Provides the ID of the task.- Returns:
- the task ID
-
equals
public boolean equals(Object o)
- Overrides:
equals
in classAbstractState
-
hashCode
public int hashCode()
- Overrides:
hashCode
in classAbstractState
-
-