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
andSinkTask
.
-
-
Method Summary
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
start(Map<String,String> props)
Start the Taskvoid
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 correspondingConnector
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.
-
-