Interface ConnectorContext

All Known Subinterfaces:
SinkConnectorContext, SourceConnectorContext

public interface ConnectorContext
ConnectorContext allows Connectors to proactively interact with the Kafka Connect runtime.
  • Method Summary

    Modifier and Type
    Method
    Description
    void
    Raise an unrecoverable exception to the Connect framework.
    void
    Requests that the runtime reconfigure the Tasks for this source.
  • Method Details

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