View Kafka exchanges
curl --request GET \
--url https://api.example.com/{MOCK_ADAPTER_UR}L/api/kafka-exchanges/import requests
url = "https://api.example.com/{MOCK_ADAPTER_UR}L/api/kafka-exchanges/"
response = requests.get(url)
print(response.text)const options = {method: 'GET'};
fetch('https://api.example.com/{MOCK_ADAPTER_UR}L/api/kafka-exchanges/', 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/{MOCK_ADAPTER_UR}L/api/kafka-exchanges/",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "https://api.example.com/{MOCK_ADAPTER_UR}L/api/kafka-exchanges/"
req, _ := http.NewRequest("GET", url, nil)
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("https://api.example.com/{MOCK_ADAPTER_UR}L/api/kafka-exchanges/")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/{MOCK_ADAPTER_UR}L/api/kafka-exchanges/")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Get.new(url)
response = http.request(request)
puts response.read_bodyView Kafka exchanges
GET
{MOCK_ADAPTER_UR}
L
/
api
/
kafka-exchanges
/
View Kafka exchanges
curl --request GET \
--url https://api.example.com/{MOCK_ADAPTER_UR}L/api/kafka-exchanges/import requests
url = "https://api.example.com/{MOCK_ADAPTER_UR}L/api/kafka-exchanges/"
response = requests.get(url)
print(response.text)const options = {method: 'GET'};
fetch('https://api.example.com/{MOCK_ADAPTER_UR}L/api/kafka-exchanges/', 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/{MOCK_ADAPTER_UR}L/api/kafka-exchanges/",
CURLOPT_RETURNTRANSFER => true,
CURLOPT_ENCODING => "",
CURLOPT_MAXREDIRS => 10,
CURLOPT_TIMEOUT => 30,
CURLOPT_HTTP_VERSION => CURL_HTTP_VERSION_1_1,
CURLOPT_CUSTOMREQUEST => "GET",
]);
$response = curl_exec($curl);
$err = curl_error($curl);
curl_close($curl);
if ($err) {
echo "cURL Error #:" . $err;
} else {
echo $response;
}package main
import (
"fmt"
"net/http"
"io"
)
func main() {
url := "https://api.example.com/{MOCK_ADAPTER_UR}L/api/kafka-exchanges/"
req, _ := http.NewRequest("GET", url, nil)
res, _ := http.DefaultClient.Do(req)
defer res.Body.Close()
body, _ := io.ReadAll(res.Body)
fmt.Println(string(body))
}HttpResponse<String> response = Unirest.get("https://api.example.com/{MOCK_ADAPTER_UR}L/api/kafka-exchanges/")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/{MOCK_ADAPTER_UR}L/api/kafka-exchanges/")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Get.new(url)
response = http.request(request)
puts response.read_bodyView all available Kafka exchanges
string
The URL of the mock adapter.
Last modified on July 7, 2026
Related topics
FlowX.AI 5.6.0 Release NotesFlowX.AI 5.1.0 Release NotesFlowX.AI 5.1.3 Release Notes (LTS)FlowX.AI 5.4.0 Release NotesFlowX.AI 4.7.6 Release NotesโI

