Interface ConnectorContext

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