Перейти к содержимому

Изменения документа Stream триггер

Редактировал(а) Alexandr Fokin 2026/08/28 11:44
От версии 1.4
отредактировано Alexandr Fokin
на 2026/08/28 11:43
Изменить комментарий: К данной версии нет комментариев
К версии 1.3
отредактировано Alexandr Fokin
на 2026/08/28 11:28
Изменить комментарий: К данной версии нет комментариев

Сводка

Подробности

Свойства страницы
Содержимое
... ... @@ -12,7 +12,7 @@
12 12  |(% style="width:147px" %)Offset stream триггер|(% style="width:1334px" %)(((
13 13  Можно также хранить в триггере offset (по аналогии с kakfa), в таком случае триггер может избежать перепроверки условия пробуждения (не проверять наличие необработанных сообщений в БД), достаточно только отслеживать значения смещений.
14 14  
15 -* Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - сообщение от процесса об обработанном смещении (содержит обработанный offset).
15 +* Вводит 2 типа события, 1 сигнал о новом сообщении (содержит offset значение), 2 - процесс идет спать (содержит offset значение).
16 16  * Вводит дополнительное состояние в триггер: максимальный offset сообщения, максимальный offset обработанного процессом сообщения, флаг состояния сна процесса
17 17  )))
18 18  |(% style="width:147px" %)Каскад триггеров|(% style="width:1334px" %)Способ для обработки конкурентных сигналов (несколько триггеров). Для процесса создается один корневой триггеров, а все другие (дочерние) триггеры передают сигнал на него.