Class ConnectorState

java.lang.Object
org.apache.kafka.connect.health.AbstractState
org.apache.kafka.connect.health.ConnectorState
public class ConnectorStateextends AbstractState
Describes the status, worker ID, and any errors associated with a connector.

  • Constructor Details

    • ConnectorState

      public ConnectorState(String state, String workerId, String traceMessage)
      Provides an instance of the ConnectorState.
      Parameters:
      state - - the status of connector, may not be null or empty
      workerId - - the workerId associated with the connector, may not be null or empty
      traceMessage - - any error message associated with the connector, may be null or empty

  • Method Details