Package org.apache.kafka.connect.connector

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 raiseError​(Exception e)
    Raise an unrecoverable exception to the Connect framework.
    void requestTaskReconfiguration()
    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.