THIS IS A TEST INSTANCE. ALL YOUR CHANGES WILL BE LOST!!!!
...
Code Block |
---|
w:kafka norwood$ curl -s 'http://localhost:8083/connectors?expand=status&expand=info' | jq { "blah": { "configinfo": { "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.25.241:8083" }, "tasks": [ { "id": 0, "state": "RUNNING", "worker_id": "10.200.25.241:8083" } ], "type": "source" } } } |
...