POST
/
subscriptions
{
  "id": "<string>",
  "source": "<string>",
  "sink": "<string>",
  "options": {}
}

Body

application/json
source
string
required

Source uri. Accepted forms:

  • kafka://<cluster_name>/<topic_name>, e.g. kafka://my-cluster/my-topic
sink
string
required

Sink uri. Accepted forms:

  • service://<service_name>/<service_name>, e.g. service://Counter/count
options
object | null

Additional options to apply to the subscription.

Response

Created

id
string
required
source
string
required
sink
string
required
options
object
required