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 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