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