kafka connect distributed cluster status

kc_distributed_status.md

To view the status of your kafka connect distributed cluster connectors, you can use the following command from inside the pod or machine:

curl -s localhost:8083/connectors?expand=status | jq

This will result:

{
  "inbound-kafka-to-s3": {
    "status": {
      "name": "inbound-kafka-to-s3",
      "connector": {
        "state": "RUNNING",
        "worker_id": "10.22.75.237:8083"
      },
      "tasks": [
        {
          "id": 0,
          "state": "RUNNING",
          "worker_id": "10.22.186.252:8083"
        },
        {
          "id": 1,
          "state": "RUNNING",
          "worker_id": "10.22.117.44:8083"
        },
        {
          "id": 2,
          "state": "RUNNING",
          "worker_id": "10.22.183.54:8083"
        },
        {
          "id": 3,
          "state": "RUNNING",
          "worker_id": "10.22.176.201:8083"
        },
        {
          "id": 4,
          "state": "RUNNING",
          "worker_id": "10.22.103.28:8083"
        },
        {
          "id": 5,
          "state": "RUNNING",
          "worker_id": "10.22.73.91:8083"
        },
        {
          "id": 6,
          "state": "RUNNING",
          "worker_id": "10.22.75.224:8083"
        },
        {
          "id": 7,
          "state": "RUNNING",
          "worker_id": "10.22.189.63:8083"
        }
      ],
      "type": "sink"
    }
  }
}