Add new Kafka exchange mock
curl --request GET \
--url https://api.example.com/{MOCK_ADAPTER_UR}/api/kafka-exchanges/ \
--header 'Content-Type: application/json' \
--data '
{
"sentMessageJson": "<string>",
"receivedMesssageJson": "<string>",
"outgoingTopic": "<string>",
"incomingTopic": "<string>"
}
'import requests
url = "https://api.example.com/{MOCK_ADAPTER_UR}/api/kafka-exchanges/"
payload = {
"sentMessageJson": "<string>",
"receivedMesssageJson": "<string>",
"outgoingTopic": "<string>",
"incomingTopic": "<string>"
}
headers = {"Content-Type": "application/json"}
response = requests.get(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'GET',
headers: {'Content-Type': 'application/json'},
body: JSON.stringify({
sentMessageJson: '<string>',
receivedMesssageJson: '<string>',
outgoingTopic: '<string>',
incomingTopic: '<string>'
})
};
fetch('https://api.example.com/{MOCK_ADAPTER_UR}/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}/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",
CURLOPT_POSTFIELDS => json_encode([
'sentMessageJson' => '<string>',
'receivedMesssageJson' => '<string>',
'outgoingTopic' => '<string>',
'incomingTopic' => '<string>'
]),
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/{MOCK_ADAPTER_UR}/api/kafka-exchanges/"
payload := strings.NewReader("{\n \"sentMessageJson\": \"<string>\",\n \"receivedMesssageJson\": \"<string>\",\n \"outgoingTopic\": \"<string>\",\n \"incomingTopic\": \"<string>\"\n}")
req, _ := http.NewRequest("GET", 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.get("https://api.example.com/{MOCK_ADAPTER_UR}/api/kafka-exchanges/")
.header("Content-Type", "application/json")
.body("{\n \"sentMessageJson\": \"<string>\",\n \"receivedMesssageJson\": \"<string>\",\n \"outgoingTopic\": \"<string>\",\n \"incomingTopic\": \"<string>\"\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/{MOCK_ADAPTER_UR}/api/kafka-exchanges/")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Get.new(url)
request["Content-Type"] = 'application/json'
request.body = "{\n \"sentMessageJson\": \"<string>\",\n \"receivedMesssageJson\": \"<string>\",\n \"outgoingTopic\": \"<string>\",\n \"incomingTopic\": \"<string>\"\n}"
response = http.request(request)
puts response.read_bodyAdd new Kafka exchange mock
GET
{MOCK_ADAPTER_UR}
/
api
/
kafka-exchanges
/
Add new Kafka exchange mock
curl --request GET \
--url https://api.example.com/{MOCK_ADAPTER_UR}/api/kafka-exchanges/ \
--header 'Content-Type: application/json' \
--data '
{
"sentMessageJson": "<string>",
"receivedMesssageJson": "<string>",
"outgoingTopic": "<string>",
"incomingTopic": "<string>"
}
'import requests
url = "https://api.example.com/{MOCK_ADAPTER_UR}/api/kafka-exchanges/"
payload = {
"sentMessageJson": "<string>",
"receivedMesssageJson": "<string>",
"outgoingTopic": "<string>",
"incomingTopic": "<string>"
}
headers = {"Content-Type": "application/json"}
response = requests.get(url, json=payload, headers=headers)
print(response.text)const options = {
method: 'GET',
headers: {'Content-Type': 'application/json'},
body: JSON.stringify({
sentMessageJson: '<string>',
receivedMesssageJson: '<string>',
outgoingTopic: '<string>',
incomingTopic: '<string>'
})
};
fetch('https://api.example.com/{MOCK_ADAPTER_UR}/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}/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",
CURLOPT_POSTFIELDS => json_encode([
'sentMessageJson' => '<string>',
'receivedMesssageJson' => '<string>',
'outgoingTopic' => '<string>',
'incomingTopic' => '<string>'
]),
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/{MOCK_ADAPTER_UR}/api/kafka-exchanges/"
payload := strings.NewReader("{\n \"sentMessageJson\": \"<string>\",\n \"receivedMesssageJson\": \"<string>\",\n \"outgoingTopic\": \"<string>\",\n \"incomingTopic\": \"<string>\"\n}")
req, _ := http.NewRequest("GET", 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.get("https://api.example.com/{MOCK_ADAPTER_UR}/api/kafka-exchanges/")
.header("Content-Type", "application/json")
.body("{\n \"sentMessageJson\": \"<string>\",\n \"receivedMesssageJson\": \"<string>\",\n \"outgoingTopic\": \"<string>\",\n \"incomingTopic\": \"<string>\"\n}")
.asString();require 'uri'
require 'net/http'
url = URI("https://api.example.com/{MOCK_ADAPTER_UR}/api/kafka-exchanges/")
http = Net::HTTP.new(url.host, url.port)
http.use_ssl = true
request = Net::HTTP::Get.new(url)
request["Content-Type"] = 'application/json'
request.body = "{\n \"sentMessageJson\": \"<string>\",\n \"receivedMesssageJson\": \"<string>\",\n \"outgoingTopic\": \"<string>\",\n \"incomingTopic\": \"<string>\"\n}"
response = http.request(request)
puts response.read_bodyView all available Kafka exchanges
string
The URL of the mock adapter.
string
The mocked JSON message that the integration will send
string
The JSON message the integration should reply with
string
Should match the topic the engine listens on for replies from the integration
string
Should match the topic name that the integration listens on
Last modified on July 7, 2026
Related topics
FlowX.AI 5.9.0 Release NotesFlowX.AI 5.6.0 Release NotesFlowX.AI 5.4.0 Release NotesFlowX.AI 5.11.0 Release NotesDeployment guidelines v5.4.0โI

