Поток трансформации c вызовом REST сервиса#

Пример потока трансформации c вызовом REST сервиса:
{
flow: {
name: "JobName"
source: [${source}]
restUrls {
testGet: "http://localhost:12345/test"
}
}
source: {
name: "simple transformation"
type: "source"
topic: "input"
config: ${defaults.kafka}
destination: ${transformStep}
}
transformStep: {
name: "transformation"
type: "dsl"
format: {
input: "json"
output: "json"
}
dsl: {
path: "event.tr"
}
destination: ${destination}
}
destination: {
name: "output"
type: "destination"
topic: "output"
config: ${defaults.kafka}
}
}