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 the sink task can use as it 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 kafkaOffset of the record in the Kafka topic-partition 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.