Package org.apache.kafka.connect.sink

package org.apache.kafka.connect.sink

Provides an API for implementing sink connectors which write Kafka records to external applications.

Class	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).
SinkConnector	SinkConnectors implement the Connector interface to send Kafka data to another system.
SinkConnectorContext	A context to allow a SinkConnector to interact with the Kafka Connect runtime.
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.
SinkTaskContext	Context passed to SinkTasks, allowing them to access utilities in the Kafka Connect runtime.