Interface ConnectorContext
-
- All Known Subinterfaces:
SinkConnectorContext
,SourceConnectorContext
public interface ConnectorContext
ConnectorContext allows Connectors to proactively interact with the Kafka Connect runtime.
-
-
Method Summary
All Methods Instance Methods Abstract Methods 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 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.
-
-