Class SourceConnector

java.lang.Object
org.apache.kafka.connect.connector.Connector
org.apache.kafka.connect.source.SourceConnector
All Implemented Interfaces:
Versioned

public abstract class SourceConnector extends Connector
SourceConnectors implement the connector interface to pull data from another system and send it to Kafka.
  • Constructor Details

    • SourceConnector

      public SourceConnector()
  • Method Details

    • context

      protected SourceConnectorContext context()
      Description copied from class: Connector
      Returns the context object used to interact with the Kafka Connect runtime.
      Overrides:
      context in class Connector
      Returns:
      the context for this Connector.