Настройка BPMN-элемента Kafka Consumer Connector

После добавления BPMN-элемента на схему бизнес-процесса вам нужно настроить параметры этого BPMN-элемента.

Чтобы настроить параметры BPMN-элемента Kafka Consumer Connector:

На BPMN-схеме выберите элемент Kafka Consumer Connector.
На панели справа укажите следующие параметры BPMN-элемента:
- Topic (обязательный параметр): введите имя топика Kafka, например, SomeTopic.
  
  Если в топике Kafka вы хотите обрабатывать события об изменении данных класса модели данных, имя топика Kafka должно совпадать со значением параметра ENV/Kafka__DefaultProducerTopic в конфигурационном файле сервиса доступа к хранилищу данных storagedata.
- Autogenerate consumer group id (обязательный параметр): если вы хотите для каждого экземпляра процесса сформировать новый идентификатор Kafka consumer group, введите True.
- Message type: из раскрывающегося списка выберите формат сообщения Kafka:
  - Raw json: данные в формате JSON.
  - Storage event: данные в формате JSON определенной структуры, которую использует сервис доступа к хранилищу данных storagedata:
```
 "mutation": //формат для событий Kafka и для сервиса управления событиями Платформы
 {
   "operation":"enum", // тип операции с данными класса: "insert","update","delete"
   "projectName":"string", // имя проекта
   "className": "string", // имя класса
   "idType":"enum", // тип идентификатора: "int", "guid"
   "idValue":"string"// сериализация в integer или guid в зависимости от idType
 }
```
- Process conditions variables (обязательный параметр): введите условие в формате JSON с именами переменных, которые будут использоваться в параметре Activation condition. В качестве значения переменной в этом параметре используйте переменные процесса. Вы можете использовать выражение на языке FEEL для описания значения этого параметра. Следующий фрагмент кода демонстирует пример описания этого параметра:
```
{
  "local": processVariable
}
```
- Activation condition (обязательный параметр): введите условие, которому должно соответствовать сообщение Kafka для срабатывания подписки. Вы можете использовать выражение на языке FEEL для описания значения этого параметра. Следующий фрагмент кода демонстрирует пример описания этого параметра:
```
{
  "key": {}//ключ сообщения kafka
  "value": {}//текст сообщения kafka
}
```
  Следующий фрагмент кода демонстрирует пример описания этого параметра, если параметр Process conditions описан, как показано выше:
```
{
  value.name = local
}
```
- Output mapping → Result expression (обязательный параметр): введите выражение на языке FEEL для описания способа преобразования и сохранения данных сообщения Kafka в переменных бизнес-процесса. Например, введите следующее выражение:
```
  {bpmnProcessId: response.processes.bpmnProcessId}
```
- Output mapping → Result variable (обязательный параметр): введите имя переменной, в которую будет записано сообщение Kafka. Следующий фрагмент кода демонстрирует пример описания этого параметра:
```
{
  "key": {}//ключ сообщения kafka
  "value": {}//текст сообщения kafka
}
```
- Extended settings (обязательный параметр): укажите расширенные параметры Kafka Consumer Connector. По умолчанию эти параметры имеют следующие значения:
  - Kafka boot servers: URL-адрес сервера, указанный в параметре Kafka__Server сервиса MDCamundaActionConnector.
  - Use offsets: false.
  - Auto offset reset: Earlest.
Вверху справа нажмите Сохранить.

Связанные статьи

Создание класса

Получение события об изменении данных класса

Связанные статьи​

Связанные статьи