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

Rest Api Transformation.png

Пример потока трансформации 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}
  }
}