Package org.apache.kafka.connect.sink
package org.apache.kafka.connect.sink
-
ClassDescriptionComponent that the sink task can use as it
SinkTask.put(java.util.Collection)
.SinkConnectors implement the Connector interface to send Kafka data to another system.A context to allow aSinkConnector
to interact with the Kafka Connect runtime.SinkRecord is aConnectRecord
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 is a Task that takes records loaded from Kafka and sends them to another system.Context passed to SinkTasks, allowing them to access utilities in the Kafka Connect runtime.