Class ConnectorState

java.lang.Object
org.apache.kafka.connect.health.AbstractState
org.apache.kafka.connect.health.ConnectorState

public class ConnectorState
extends 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