Skip to content

Instantly share code, notes, and snippets.

@hpgrahsl
Created October 12, 2018 20:29
Show Gist options
  • Save hpgrahsl/c8b12e7044ed14eff53a1fd19227194d to your computer and use it in GitHub Desktop.
Save hpgrahsl/c8b12e7044ed14eff53a1fd19227194d to your computer and use it in GitHub Desktop.
post the sink connector config to Kafka Connect REST endpoint
curl -X POST \
http://localhost:8083/connectors \
-H 'Content-Type: application/json' \
-d '{ "name": "cosmosdb-sink",
"config":
{
"topics":"blogpost",
"connector.class":"at.grahsl.kafka.connect.mongodb.MongoDbSinkConnector",
"key.converter":"org.apache.kafka.connect.json.JsonConverter",
"key.converter.schemas.enable":false,
"value.converter":"org.apache.kafka.connect.json.JsonConverter",
"value.converter.schemas.enable":false,
"mongodb.connection.uri": "<PUT_YOUR_CONNECTION_STRING_HERE_AND_ADD_DATABASE_NAME>",
"mongodb.collection": "blogpost"
}
}
'
Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment