Versions Compared

Key

  • This line was added.
  • This line was removed.
  • Formatting was changed.

...

the following expansions are allowed

expandclass returned

status

ConnectorStateInfo
infoConnectorInfo


Code Block
w:kafka norwood$ curl -s http://localhost:8083/connectors | jq
[
  "blah"
]

...

Code Block
w:kafka norwood$ curl -s 'http://localhost:8083/connectors?expand=status&expand=trueconfig' | jq
{
  "blah": {
    "config": {
      "name": "blah",
      "config": {
        "connector.class": "org.apache.kafka.connect.file.FileStreamSourceConnector",
        "file": "/tmp/lol",
        "tasks.max": "10",
        "name": "blah",
        "topic": "test-topic"
      },
      "tasks": [
        {
          "connector": "blah",
          "task": 0
        }
      ],
      "type": "source"
    },
    "status": {
      "name": "blah",
      "connector": {
        "state": "RUNNING",
        "worker_id": "10.200.725.135241:8083"
      },
      "tasks": [
        {
          "id": 0,
          "state": "RUNNING",
          "worker_id": "10.200.725.135241:8083"
        }
      ],
      "type": "source"
    }
  }
}


Proposed Changes

The changes are ~entirely in ConnectorsResource and the Herders. PR: https://github.com/apache/kafka/pull/6658

...