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