Method Detail

• requestTaskReconfiguration

  void requestTaskReconfiguration()

  Requests that the runtime reconfigure the Tasks for this source. This should be used to indicate to the runtime that something about the input/output has changed (e.g. partitions added/removed) and the running Tasks will need to be modified.

• raiseError

  void raiseError(Exception e)

  Raise an unrecoverable exception to the Connect framework. This will cause the status of the connector to transition to FAILED.

  Parameters:

  e - Exception to be raised.