Я использую Apache Flink для обработки потока. После подписки сообщений из источника (например,...

Можно ли динамически устанавливать идентификатор корреляции при использовании федеративного обмена...

У меня есть набор правил. Для количества правил нет верхней границы. С другой стороны у меня есть...

У меня есть сценарий использования, когда мне нужно «объединить» несколько тем Kafka на основе...

Я разработчик мессенджеров и пытаюсь вычислить DAU / MAU, используя поток событий пользовательских...

Я пытаюсь обогатить мой входной поток дополнительным атрибутом, который заполняется через приемник...

Мое намерение - объединить атрибуты из двух потоков в siddhi. Я использую атрибут "join" с...