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