kpatelatwork commented on pull request #10822: URL: https://github.com/apache/kafka/pull/10822#issuecomment-864493282
Fired up local kafka server and kafka connect and was able to curl the API locally. > ➜ kafka git:(KAFKA-4793) ✗ curl http://192.168.1.220:8083/connectors/local-file-source/status {"name":"local-file-source","connector":{"state":"RUNNING","worker_id":"192.168.1.220:8083"},"tasks":[{"id":0,"state":"RUNNING","worker_id":"192.168.1.220:8083"}],"type":"source"}% ➜ kafka git:(KAFKA-4793) ✗ curl -XPOST http://192.168.1.220:8083/connectors/local-file-source/restart\?includeTasks\=true\&onlyFailed\=false {"name":"local-file-source","connector":{"state":"RESTARTING","worker_id":"192.168.1.220:8083"},"tasks":[{"id":0,"state":"RESTARTING","worker_id":"192.168.1.220:8083"}],"type":"source"}% ➜ kafka git:(KAFKA-4793) ✗ curl -XPOST http://192.168.1.220:8083/connectors/local-file-source/restart\?includeTasks\=false\&onlyFailed\=false ➜ kafka git:(KAFKA-4793) ✗ curl -XPOST http://192.168.1.220:8083/connectors/local-file-source/restart\?includeTasks\=false\&onlyFailed\=true {"name":"local-file-source","connector":{"state":"RUNNING","worker_id":"192.168.1.220:8083"},"tasks":[{"id":0,"state":"RUNNING","worker_id":"192.168.1.220:8083"}],"type":"source"}% ➜ kafka git:(KAFKA-4793) ✗ curl -XPOST http://192.168.1.220:8083/connectors/local-file-source/restart\?includeTasks\=true\&onlyFailed\=true {"name":"local-file-source","connector":{"state":"RUNNING","worker_id":"192.168.1.220:8083"},"tasks":[{"id":0,"state":"RUNNING","worker_id":"192.168.1.220:8083"}],"type":"source"}% ➜ kafka git:(KAFKA-4793) ✗ curl -XPOST http://192.168.1.220:8083/connectors/local-file-source/restart\?includeTasks\=true {"name":"local-file-source","connector":{"state":"RESTARTING","worker_id":"192.168.1.220:8083"},"tasks":[{"id":0,"state":"RESTARTING","worker_id":"192.168.1.220:8083"}],"type":"source"}% -- This is an automated message from the Apache Git Service. To respond to the message, please log on to GitHub and use the URL above to go to the specific comment. For queries about this service, please contact Infrastructure at: us...@infra.apache.org