Точки назначения событий#

Описание точки назначения событий#

Назначение описывается аналогично источника, поле type имеет значение destination:

1. name — название источника событий;

2. topic — имя топиков для записи сообщений по умолчанию, опциональный, по умолчанию «output»;

3. config — конфигурация транспорта назначения.

Поле config содержит специфическую конфигурацию транспорта:

• Apache Kafka: аналогично источнику;

• gRPC: аналогично источнику;

• shared-grpc: аналогично источнику;

• Файл (file): аналогично источнику.

Пример конфигурации точек назначения событий с типом kafka#

destination: {
   name: "kafka"
   type: "destination"
   topic: "output"
   config: {
      type: "kafka"
      "bootstrap.servers":"localhost:9092"
      consumer: {
         "group.id": "event-process-flow-group"
         "client.id": "event-process-flow-client"
      }
      producer: {
         "client.id": "event-process-flow-producer"
      }
   }
}

Пример конфигурации точек назначения событий с типом grpc#

destination: {
   name: "grpc"
   type: "destination"
   topic: "output"
   config: {
      type: "grpc"
      url: "fpss://K2_IAZCommon.Common/System/TESTA/1"
      host: "reactivestreamadapter-evta-os-evpc-demo"
      port: 8081
      timeout: 30000
   }
}

Настройка транспорта с использованием EVTA#

Для подключения к транспорту с использованием интеграционного адаптера под формат CloudEvent (EVTA), необходимо в конфигурации точек назначения указать следующие настройки c типом подключения shared-grpc:

Также возможно использование параметров SSL-контекста.

Пример конфигурации точек назначения событий с типом shared-grpc#

destination: {
    name: "kafka"
    type: "destination"
    topic: "output"
    cloudEvent: "true"
    config: {
        type: "shared-grpc"
        timeout: 30000
        bufferSize: 1000
        host: "localhost"
        port: 8989
        source: "ru.sbt.ss.event2"
        restartAttempts: 3
    }
}

Настройка транспорта с использованием файла#

Простая запись в файл (запись выполняется во время чекпоинтов и при завершении работы обработчика, рекомендуется для использования с конечными источниками событий (в данный момент только «file»)):

1. type — тип транспорта, значение: «file» (аналогично источнику);

2. path — полный путь до директории назначения;

3. partPrefix — префикс имен файлов;

4. partSuffix — суффикс имен файлов.

Пример конфигурации точек назначения событий с типом file#

destination: {
      name: "file"
      type: "destination"
      topic: "output"
      config: {
        type: "file"
        path: "/full/path/to/directory/"
        partPrefix: "output"
        partSuffix: ".txt"
        }
    }