Skip to content

Instantly share code, notes, and snippets.

@neovintage
Created March 31, 2022 23:14
Show Gist options
  • Star 0 You must be signed in to star a gist
  • Fork 0 You must be signed in to fork a gist
  • Save neovintage/80d7d4aa198f453803f988b33d86685b to your computer and use it in GitHub Desktop.
Save neovintage/80d7d4aa198f453803f988b33d86685b to your computer and use it in GitHub Desktop.
Conduit Connect Wrapper API Call
curl --header "Content-Type: application/json" \
--request POST
--data '{
"type": "TYPE_SOURCE",
"plugin": "~/kafka-connector-plugin",
"pipeline_id": "...",
"config": {
"name": "my-pg-source",
"settings": {
"wrapper.connector.class": "io.aiven.connect.jdbc.JdbcSourceConnector",
"connection.url": "jdbc:postgresql://localhost/test-db",
"connection.user": "username",
"connection.password": "password",
"incrementing.column.name": "id",
"mode": "incrementing",
"tables": "customers",
"topic.prefix": "my_topic_prefix"
}
}
}' \
-g http://localhost:8080/v1/connectors
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment