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 the connector'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
.
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.
|