Class VerifiableSourceConnector

java.lang.Object
org.apache.kafka.connect.connector.Connector
org.apache.kafka.connect.source.SourceConnector
org.apache.kafka.connect.tools.VerifiableSourceConnector
All Implemented Interfaces:
Versioned
public class VerifiableSourceConnector extends SourceConnector
A connector primarily intended for system tests.
See Also:

  • Constructor Details

    • VerifiableSourceConnector

      public VerifiableSourceConnector()

  • Method Details

    • version

      public String version()
      Description copied from interface: Versioned
      Get the version of this component.
      Returns:
      the version, formatted as a String. The version may not be null or empty.

    • start

      public void start(Map<String,String> props)
      Description copied from class: Connector
      Start this Connector. This method will only be called on a clean Connector, i.e. it has either just been instantiated and initialized or Connector.stop() has been invoked.
      Specified by:
      start in class Connector
      Parameters:
      props - configuration settings

    • taskClass

      public Class<? extends Task> taskClass()
      Description copied from class: Connector
      Returns the Task implementation for this Connector.
      Specified by:
      taskClass in class Connector

    • taskConfigs

      public List<Map<String,String>> taskConfigs(int maxTasks)
      Description copied from class: Connector
      Returns a set of configurations for Tasks based on the current configuration, producing at most maxTasks configurations.
      Specified by:
      taskConfigs in class Connector
      Parameters:
      maxTasks - maximum number of configurations to generate
      Returns:
      configurations for Tasks

    • stop

      public void stop()
      Description copied from class: Connector
      Stop this connector.
      Specified by:
      stop in class Connector

    • config

      public ConfigDef config()
      Description copied from class: Connector
      Define the configuration for the connector.
      Specified by:
      config in class Connector
      Returns:
      The ConfigDef for this connector; may not be null.