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
    Component 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 a SinkConnector to interact with the Kafka Connect runtime.
    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 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.