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.

Constructor Summary

Constructors

Constructor	Description
TaskState(int taskId, String state, String workerId, String trace)	Provides an instance of TaskState.

Method Summary

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

Methods inherited from class java.lang.Object

clone, finalize, getClass, notify, notifyAll, wait, wait, wait

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

taskId

public int taskId()

Provides the ID of the task.

Returns:

the task ID

equals

public boolean equals(Object o)

Overrides:

equals in class AbstractState

hashCode

public int hashCode()

Overrides:

hashCode in class AbstractState

toString

public String toString()

Overrides:

toString in class Object