Package org.apache.kafka.connect.sink

  • Interface Summary
    Interface Description
    ErrantRecordReporter
    Component that the sink task can use as it SinkTask.put(java.util.Collection).
    SinkConnectorContext
    A context to allow a SinkConnector 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 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.