Class 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 Detail

      • SourceConnector

        public SourceConnector()
    • Method Detail

      • 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.