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.
-
Constructor Details
-
ConnectorHealth
public ConnectorHealth(String name, ConnectorState connectorState, Map<Integer,TaskState> tasks, ConnectorType type)
-
-
Method Details
-
name
Provides the name of the connector.- Returns:
- name, never
null
or empty
-
connectorState
Provides the current state of the connector.- Returns:
- the connector state, never
null
-
tasksState
Provides the current state of the connector tasks.- Returns:
- the state for each task ID; never
null
-
type
Provides the type of the connector.- Returns:
- type, never
null
-
equals
-
hashCode
public int hashCode() -
toString
-