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 and Description
ConnectorHealth(String name, ConnectorState connectorState, Map<Integer,TaskState> tasks, ConnectorType type)

Method Summary

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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

ConnectorHealth

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

Method Detail

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