Package org.apache.kafka.connect.health

Class ConnectorHealth

java.lang.Object

org.apache.kafka.connect.health.ConnectorHealth

public class ConnectorHealth
extends Object

Provides basic health information about the connector and its tasks.

Constructor Summary

Constructors

Constructor	Description
ConnectorHealth(String name, ConnectorState connectorState, Map<Integer,TaskState> tasks, ConnectorType type)

Method Summary

Modifier and Type	Method	Description
ConnectorState	connectorState()	Provides the current state of the connector.
boolean	equals(Object o)
int	hashCode()
String	name()	Provides the name of the connector.
Map<Integer,TaskState>	tasksState()	Provides the current state of the connector tasks.
String	toString()
ConnectorType	type()	Provides the type of the connector.

Methods inherited from class java.lang.Object

getClass, notify, notifyAll, wait, wait, wait

Constructor Details

ConnectorHealth

public ConnectorHealth(String name,
 ConnectorState connectorState,
 Map<Integer,TaskState> tasks,
 ConnectorType type)

Method Details

name

public String name()

Provides the name of the connector.

Returns:

name, never null or empty

connectorState

public ConnectorState connectorState()

Provides the current state of the connector.

Returns:

the connector state, never null

tasksState

public Map<Integer,TaskState> tasksState()

Provides the current state of the connector tasks.

Returns:

the state for each task ID; never null

type

public ConnectorType type()

Provides the type of the connector.

Returns:

type, never null

equals

public boolean equals(Object o)

Overrides:

equals in class Object

hashCode

public int hashCode()

Overrides:

hashCode in class Object

toString

public String toString()

Overrides:

toString in class Object