GET /connectors/(string:name)/tasks
Gets a list of tasks currently running for the connector.
Description
Parameters | Description |
---|---|
tasks (array) | List of active task configurations created by the connector. |
tasks[i].id (string) | ID of the task. |
tasks[i].id.connector (string) | Name of the connector that the task belongs to. |
tasks[i].id.task (int) | Task ID within the connector. |
tasks[i].config (map) | Configuration parameters for the task. |
Syntax
http://<host>:8083/connectors/<connector_name>/tasks
Request Example
GET /connectors/hdfs-sink-connector/tasks HTTP/1.1 Host: connect.example.com
Response Example
HTTP/1.1 200 OK
[ {
"task.class": "io.confluent.connect.hdfs.HdfsSinkTask",
"topics": "test-topic",
"hdfs.url": "hdfs://fakehost:9000",
"hadoop.conf.dir": "/opt/hadoop/conf",
"hadoop.home": "/opt/hadoop",
"flush.size": "100",
"rotate.interval.ms": "1000" },
{
"task.class": "io.confluent.connect.hdfs.HdfsSinkTask",
"topics": "test-topic",
"hdfs.url": "hdfs://fakehost:9000",
"hadoop.conf.dir": "/opt/hadoop/conf",
"hadoop.home": "/opt/hadoop",
"flush.size": "100",
"rotate.interval.ms": "1000" }
]