Kafka Connect 2.0.1: GET /connectors/(string:name)/tasks

Gets a list of tasks currently running for the connector.

Description

Table 1. Parameters
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"     } 
]