Kafka Connect HTTP Request - kayform/bwcontrol GitHub Wiki

GET	command	curl -i -X GET -H "Content-Type: application/json" http://K4M-KAFKA-1:8083/connectors/TV
	URL	http://K4M-KAFKA-1:8083/connectors/TV
	200	HTTP/1.1 200 OKDate: Fri, 09 Sep 2016 03:27:42 GMT Content-Type: application/json Content-Length: 381 Server: Jetty(9.2.15.v20160210){""name"":""TV"",""config"":{""topics"":""TV.typetest,TV.typetest2,"",""hdfs.url"":""hdfs://K4M-BIGDATA-1:8020/user/hive/warehouse/test-postgres-jdbc-test2"",""tasks.max"":""3"",""flush.size"":""10000"",""connector.class"":""io.confluent.connect.hdfs.HdfsSinkConnector"",""rotate.interval.ms"":""60000"",""name"":""TV""},""tasks"":[{""connector"":""TV"",""task"":0},{""connector"":""TV"",""task"":1},{""connector"":""TV"",""task"":2}]}
	404	HTTP/1.1 404 Not FoundDate: Fri, 09 Sep 2016 03:26:28 GMTContent-Type: application/jsonContent-Length: 56Server: Jetty(9.2.15.v20160210){"error_code":404,"message":"Connector hdfsA not found"}
CREATE	command	curl -i -X POST -H "Content-Type: application/json" -d '{"name": "default-config","config": {"topics": "default-topic", "hdfs.url": "hdfs://K4M-BIGDATA-1:8020/user/hive/warehouse/test-postgres-jdbc-test2", "tasks.max": "3", "flush.size": "10000", "connector.class": "io.confluent.connect.hdfs.HdfsSinkConnector", "rotate.interval.ms": "60000"}}' http://K4M-KAFKA-1:8083/connectors/
	URL	http://K4M-KAFKA-1:8083/connectors/
	201	HTTP/1.1 201 Created Date: Fri, 09 Sep 2016 03:30:13 GMT Location: http://K4M-KAFKA-1:8083/connectors/hdfs-sinkYY Content-Type: application/json Content-Length: 165 Server: Jetty(9.2.15.v20160210)
	409	HTTP/1.1 409 Conflict Date: Fri, 09 Sep 2016 03:33:48 GMT Content-Type: application/json Content-Length: 70 Server: Jetty(9.2.15.v20160210)

| |PUT|command|curl -i -X PUT -H "Content-Type: application/json" -d '{"flush.size":"10001","topics":"123","connector.class":"io.confluent.connect.hdfs.HdfsSinkConnector"}' http://K4M-KAFKA-1:8083/connectors/hdfs-sinkYY/config| | |URL|http://K4M-KAFKA-1:8083/connectors/hdfs-sinkYY/config| | |200|HTTP/1.1 200 OK Date: Fri, 09 Sep 2016 03:34:24 GMT Content-Type: application/json Content-Length: 165 Server: Jetty(9.2.15.v20160210) {""name"":""hdfs-sinkYY"",""config"":{""flush.size"":""10001"",""topics"":""123"",""connector.class"":""io.confluent.connect.hdfs.HdfsSinkConnector"",""name"":""hdfs-sinkYY""},""tasks"":[]}| | |command|curl -i -X PUT -H "Content-Type: application/json" -d '{"flush.size":"10001","topics":"123","connector.class":"io.confluent.connect.hdfs.HdfsSinkConnector"}' http://K4M-KAFKA-1:8083/connectors/TTT/config| | |URL|http://K4M-KAFKA-1:8083/connectors/TTT/config| | |201|HTTP/1.1 201 Created Date: Fri, 09 Sep 2016 03:35:11 GMT Location: http://K4M-KAFKA-1:8083/connectors/TTT Content-Type: application/json Content-Length: 149 Server: Jetty(9.2.15.v20160210){""name"":""TTT"",""config"":{""flush.size"":""10001"",""topics"":""123"",""connector.class"":""io.confluent.connect.hdfs.HdfsSinkConnector"",""name"":""TTT""},""tasks"":[]}| |DELETE|command|curl -i -X DELETE -H "Content-Type: application/json" http://K4M-KAFKA-1:8083/connectors/hdfs-sinkYY| | |URL|curl -i -X DELETE -H "Content-Type: application/json" http://K4M-KAFKA-1:8083/connectors/hdfs-sinkYY| | |201|"HTTP/1.1 204 No ContentDate: Fri, 09 Sep 2016 03:47:23 GMTServer: Jetty(9.2.15.v20160210)"| | |command|curl -i -X DELETE -H "Content-Type: application/json" http://K4M-KAFKA-1:8083/connectors/hdfs-sinkYY| | |URL|http://K4M-KAFKA-1:8083/connectors/hdfs-sinkYY| | |201|"HTTP/1.1 404 Not FoundDate: Fri, 09 Sep 2016 03:47:43 GMTContent-Type:application/jsonContent-Length: 62Server: Jetty(9.2.15.v20160210){""error_code"":404,""message"":""Connector hdfs-sinkYY not found""}"|