Структура файла потока «*.conf»#

{
  flow: {
    name: "JobName"
    source: ${source}
  }

# Блок-источник события. Источников может быть несколько.
  source: {
    name: "<наименование источника>"
    type: "source"
    topic: "input"
    config: ${defaults.kafka} {
      consumer: {
        "group.id": "event-process-flow-group" # Можно использовать формат e-p-f-g-<наименование обработчика>
        "client.id": "event-process-flow-client"
      }
      producer: {
        "client.id": "event-process-flow-producer"
      }
    }
    destination: ${}
  }

# ------ Здесь другие блоки, реализующие логику обработки. Например, трансформация, агрегация и др. ------

# Блок-получатель события. Получателей может быть несколько.
  destination: {
    name: "<наименование шага получения>"
    type: "destination"
    topic: "output"
    config: ${defaults.kafka}
  }
}