See: Description
| Interface | Description |
|---|---|
| ErrantRecordReporter | Component that a SinkTask can use to report problematic records (and their corresponding problems) as it writes them through SinkTask.put(java.util.Collection). |
| SinkConnectorContext | A context to allow a SinkConnector to interact with the Kafka Connect runtime. |
| SinkTaskContext | Context passed to SinkTasks, allowing them to access utilities in the Kafka Connect runtime. |
| Class | Description |
|---|---|
| SinkConnector | SinkConnectors implement the Connector interface to send Kafka data to another system. |
| SinkRecord | SinkRecord is a ConnectRecord that has been read from Kafka and includes the original Kafka record's topic, partition and offset (before any transformations have been applied) in addition to the standard fields. |
| SinkTask | SinkTask is a Task that takes records loaded from Kafka and sends them to another system. |