Class ConnectorHealth

java.lang.Object
org.apache.kafka.connect.health.ConnectorHealth
public class ConnectorHealthextends Object
Provides basic health information about the connector and its tasks.

  • Constructor Details

  • 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