Package org.apache.kafka.connect.tools

Class MockSourceTask

java.lang.Object
org.apache.kafka.connect.source.SourceTask
org.apache.kafka.connect.tools.MockSourceTask
All Implemented Interfaces:
Task
public class MockSourceTask extends SourceTask
Task implementation for MockSourceConnector.

  • Constructor Details

    • MockSourceTask

      public MockSourceTask()

  • Method Details

    • version

      public String version()
      Description copied from interface: Task
      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

      public void start(Map<String,String> config)
      Description copied from class: SourceTask
      Start the Task. This should handle any configuration parsing and one-time setup of the task.
      Specified by:
      start in interface Task
      Specified by:
      start in class SourceTask
      Parameters:
      config - initial configuration

    • poll

      public List<SourceRecord> poll()
      Description copied from class: SourceTask
      Poll this source task for new records. If no data is currently available, this method should block but return control to the caller regularly (by returning null) in order for the task to transition to the PAUSED state if requested to do so.

      The task will be stopped on a separate thread, and when that happens this method is expected to unblock, quickly finish up any remaining processing, and return.

      Specified by:
      poll in class SourceTask
      Returns:
      a list of source records

    • stop

      public void stop()
      Description copied from class: SourceTask
      Signal this SourceTask to stop. In SourceTasks, this method only needs to signal to the task that it should stop trying to poll for new data and interrupt any outstanding poll() requests. It is not required that the task has fully stopped. Note that this method necessarily may be invoked from a different thread than SourceTask.poll() and SourceTask.commit().

      For example, if a task uses a Selector to receive data over the network, this method could set a flag that will force SourceTask.poll() to exit immediately and invoke wakeup() to interrupt any ongoing requests.

      Specified by:
      stop in interface Task
      Specified by:
      stop in class SourceTask