curl --request POST \
--url https://api.example.com/kafka-clusters \
--header 'Content-Type: application/json' \
--data '
{
"name": "<string>",
"properties": {}
}
'import requests
url = "https://api.example.com/kafka-clusters"
payload = {
"name": "<string>",
"properties": {}
}
headers = {"Content-Type": "application/json"}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {'Content-Type': 'application/json'},
body: JSON.stringify({name: '<string>', properties: {}})
};
fetch('https://api.example.com/kafka-clusters', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://api.example.com/kafka-clusters",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
CURLOPT_POSTFIELDS => json_encode([
'name' => '<string>',
'properties' => [
]
]),
CURLOPT_HTTPHEADER => [
"Content-Type: application/json"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "https://api.example.com/kafka-clusters"
payload := strings.NewReader("{\n \"name\": \"<string>\",\n \"properties\": {}\n}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("Content-Type", "application/json")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.post("https://api.example.com/kafka-clusters")
.header("Content-Type", "application/json")
.body("{\n \"name\": \"<string>\",\n \"properties\": {}\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/kafka-clusters")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Content-Type"] = 'application/json'
request.body = "{\n \"name\": \"<string>\",\n \"properties\": {}\n}"
response = http.request(request)
puts response.read_body{
"created_at": "<string>",
"name": "<string>",
"properties": {},
"info": [
{
"message": "<string>",
"code": "<string>"
}
]
}{
"message": "<string>",
"restate_code": "<string>"
}{
"message": "<string>",
"restate_code": "<string>"
}{
"message": "<string>",
"restate_code": "<string>"
}{
"message": "<string>",
"restate_code": "<string>"
}{
"message": "<string>",
"restate_code": "<string>"
}Create Kafka cluster
Registers a new Kafka cluster configuration that can be referenced by subscriptions. The cluster configuration is validated to ensure required broker properties are present.
curl --request POST \
--url https://api.example.com/kafka-clusters \
--header 'Content-Type: application/json' \
--data '
{
"name": "<string>",
"properties": {}
}
'import requests
url = "https://api.example.com/kafka-clusters"
payload = {
"name": "<string>",
"properties": {}
}
headers = {"Content-Type": "application/json"}
response = requests.post(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'POST',
headers: {'Content-Type': 'application/json'},
body: JSON.stringify({name: '<string>', properties: {}})
};
fetch('https://api.example.com/kafka-clusters', options)
.then(res => res.json())
.then(res => console.log(res))
.catch(err => console.error(err));<?php
$curl = curl_init();
curl_setopt_array($curl, [
CURLOPT_URL => "https://api.example.com/kafka-clusters",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "POST",
CURLOPT_POSTFIELDS => json_encode([
'name' => '<string>',
'properties' => [
]
]),
CURLOPT_HTTPHEADER => [
"Content-Type: application/json"
],
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"strings"
"net/http"
"io"
)
func main() {
url := "https://api.example.com/kafka-clusters"
payload := strings.NewReader("{\n \"name\": \"<string>\",\n \"properties\": {}\n}")
req, _ := http.NewRequest("POST", url, payload)
req.Header.Add("Content-Type", "application/json")
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.post("https://api.example.com/kafka-clusters")
.header("Content-Type", "application/json")
.body("{\n \"name\": \"<string>\",\n \"properties\": {}\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/kafka-clusters")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Post.new(url)
request["Content-Type"] = 'application/json'
request.body = "{\n \"name\": \"<string>\",\n \"properties\": {}\n}"
response = http.request(request)
puts response.read_body{
"created_at": "<string>",
"name": "<string>",
"properties": {},
"info": [
{
"message": "<string>",
"code": "<string>"
}
]
}{
"message": "<string>",
"restate_code": "<string>"
}{
"message": "<string>",
"restate_code": "<string>"
}{
"message": "<string>",
"restate_code": "<string>"
}{
"message": "<string>",
"restate_code": "<string>"
}{
"message": "<string>",
"restate_code": "<string>"
}Body
Create Kafka cluster request
Cluster Name
Name for the Kafka cluster, used to identify this Kafka cluster configuration in subscriptions. Must be a valid hostname format.
Properties
Kafka cluster configuration properties. Must contain either 'bootstrap.servers' or 'metadata.broker.list'.
For a full list of configuration properties, check the librdkafka documentation.
Show child attributes
Show child attributes
Response
Kafka cluster created successfully
Kafka cluster simple response.
Created at
When the Kafka cluster configuration was created.
Cluster Name
Name for the Kafka cluster, used to identify this Kafka cluster configuration in subscriptions. Must be a valid hostname format.
Properties
Properties for connecting to the kafka cluster.
For a full list of configuration properties, check the librdkafka documentation.
Show child attributes
Show child attributes
Info
List of configuration/deprecation information related to this deployment.
Show child attributes
Show child attributes