Class SinkConnector

java.lang.Object
org.apache.kafka.connect.connector.Connector
org.apache.kafka.connect.sink.SinkConnector
All Implemented Interfaces:
Versioned

public abstract class SinkConnector
extends Connector
SinkConnectors implement the Connector interface to send Kafka data to another system.
  • Field Details

    • TOPICS_CONFIG

      public static final String TOPICS_CONFIG

      Configuration key for the list of input topics for this connector.

      Usually this setting is only relevant to the Kafka Connect framework, but is provided here for the convenience of Connector developers if they also need to know the set of topics.

      See Also:
      Constant Field Values
  • Constructor Details

    • SinkConnector

      public SinkConnector()
  • Method Details

    • context

      protected SinkConnectorContext 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.