Package org.apache.kafka.connect.connector

Interface Task

All Known Implementing Classes:
SinkTask, SourceTask
public interface Task

Tasks contain the code that actually copies data to/from another system. They receive a configuration from their parent Connector, assigning them a fraction of a Kafka Connect job's work. The Kafka Connect framework then pushes/pulls data from the Task. The Task must also be able to respond to reconfiguration requests.

Task only contains the minimal shared functionality between SourceTask and SinkTask.

  • Method Summary

    Modifier and Type Method Description
    void start​(Map<String,​String> props)
    Start the Task
    void stop()
    Stop this task.
    String version()
    Get the version of this task.

  • Method Details

    • version

      String version()
      Get the version of this task. Usually this should be the same as the corresponding Connector class's version.
      Returns:
      the version, formatted as a String

    • start

      void start​(Map<String,​String> props)
      Start the Task
      Parameters:
      props - initial configuration

    • stop

      void stop()
      Stop this task.