Package org.apache.kafka.connect.source

package org.apache.kafka.connect.source
  • Class
    SourceConnectors implement the connector interface to pull data from another system and send it to Kafka.
    A context to allow a SourceConnector to interact with the Kafka Connect runtime.
    SourceRecords are generated by SourceTasks and passed to Kafka Connect for storage in Kafka.
    SourceTask is a Task that pulls records from another system for storage in Kafka.
    SourceTaskContext is provided to SourceTasks to allow them to interact with the underlying runtime.