This repository was archived by the owner on Jul 16, 2023. It is now read-only.
-
Notifications
You must be signed in to change notification settings - Fork 0
Expand file tree
/
Copy pathcurlScript.bat
More file actions
2 lines (2 loc) · 1.29 KB
/
Copy pathcurlScript.bat
File metadata and controls
2 lines (2 loc) · 1.29 KB
1
2
curl --location --request POST localhost:8083/connectors/ --header "Accept: application/json" --header "Content-Type: application/json" --data-raw "{ \"name\": \"jdbc-source\", \"config\": {\"connector.class\": \"io.confluent.connect.jdbc.JdbcSourceConnector\", \"connection.url\": \"jdbc:postgresql://database:5432/project3\", \"connection.user\": \"postgres\", \"connection.password\": \"My01pass\", \"dialect.name\": \"PostgreSqlDatabaseDialect\", \"mode\": \"bulk\", \"query\": \"SELECT * FROM location;\", \"poll.interval.ms\": \"60000\", \"topic.prefix\": \"DBInfo\"}}"
curl --location --request POST localhost:8083/connectors/ --header "Accept: application/json" --header "Content-Type: application/json" --data-raw "{ \"name\": \"jdbc-sink\", \"config\": {\"tasks.max\":\"1\", \"connector.class\":\"io.confluent.connect.jdbc.JdbcSinkConnector\", \"connection.url\":\"jdbc:postgresql://database:5432/project3\", \"connection.user\":\"postgres\", \"connection.password\":\"My01pass\", \"dialect.name\":\"PostgreSqlDatabaseDialect\", \"topics\":\"results\", \"auto.create\":\"true\", \"key.converter\":\"org.apache.kafka.connect.storage.StringConverter\", \"value.converter\":\"org.apache.kafka.connect.json.JsonConverter\", \"key.converter.schemas.enable\":\"true\", \"value.converter.schemas.enable\":\"true\"}}"