Простой поток трансформации#

{
# Стартовая точка обработки
  flow: {
    name: "JobName"
    source: ${source}
  }

# Блок-источник события
  source: {
    name: "source"
    type: "source"
    topic: "input"
    config: ${defaults.kafka} {
      consumer: {
        "group.id": "event-process-flow-group" # consumer-группа обработчика при вычитке из Kafka
        "client.id": "event-process-flow-client"
        }
      producer: {
        "client.id": "event-process-flow-producer"
      }
    }
    destination: ${transformStep}
  }

# Блок трансформации
  transformStep: {
    name: "transformation"
    type: "dsl"
    dsl: {
      source: "file"
      path: "event.tr"
      }
    format : {
      input: "xml"
      output: "json"
    }
    destination: ${destination}
    error: {} # Обработка ошибок в шагах трансформации и агрегации событий
  }

# Блок-получатель события
  destination: {
    name: "output"
    type: "destination"
    topic: "output"
    config: ${defaults.kafka}
  }
}