Skip to content

Instantly share code, notes, and snippets.

@gwenshap
Created March 24, 2017 20:17
Show Gist options
  • Save gwenshap/32be0fc68b8a422a3f4917e512d31386 to your computer and use it in GitHub Desktop.
Save gwenshap/32be0fc68b8a422a3f4917e512d31386 to your computer and use it in GitHub Desktop.
validate connector with json tool
curl -X PUT -d "{\"connector.class\":\"JdbcSourceConnector\",\"connection.url\":\"jdbc:mysql://127.0.0.1:3306/test?user=root\",\"mode\":\"timestamp\", \"table.whitelist\":\"login\", \"validate.non.null\":false, \"timestamp.column.name\":\"login_time\", \"topic.prefix\":\"mysql.\", \"transforms\":\"InsertSource\", \"transforms.InsertSource.type\":\"org.apache.kafka.connect.transforms.InsertField\$Value\", \"transforms.InsertSource.static.field\":\"data_source\", \"transforms.InsertSource.static.value\":\"MyLocalMySQL\"}" localhost:8083/connector-plugins/JdbcSourceConnector/config/validate --header "content-Type:application/json" | python -m json.tool
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment