Skip to main content

Create subscription

POST 

/subscriptions

Create subscription.

Request

Bodyrequired

    sourceSource (string)required

    Source uri. Accepted forms:

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

    Sink uri. Accepted forms:

    • service://<service_name>/<service_name>, e.g. service://Counter/count
    options objectnullable

    Additional options to apply to the subscription.

    property name*string

Responses

Created

Schema
    idString (string)required
    sourcestringrequired
    sinkstringrequired
    options objectrequired
    property name*string
var client = new HttpClient();
var request = new HttpRequestMessage(HttpMethod.Post, "https://quickstart-update.documentation-beg.pages.dev/subscriptions");
request.Headers.Add("Accept", "application/json");
var content = new StringContent("{\n \"source\": \"string\",\n \"sink\": \"string\",\n \"options\": {}\n}", null, "application/json");
request.Content = content;
var response = await client.SendAsync(request);
response.EnsureSuccessStatusCode();
Console.WriteLine(await response.Content.ReadAsStringAsync());
Request Collapse all
Body required
{
  "source": "string",
  "sink": "string",
  "options": {}
}