org.apache.kafka.connect.connector

Interface ConnectorContext

@InterfaceStability.Unstable
public interface ConnectorContext

ConnectorContext allows Connectors to proactively interact with the Kafka Connect runtime.

Method Summary

Methods

Modifier and Type	Method and 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.