org.apache.kafka.connect.connector

Interface Task

All Known Implementing Classes:

SinkTask, SourceTask

@InterfaceStability.Unstable
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

Methods

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

Method Detail

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.