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

Для функции потоковой передачи Flink / Flink с отслеживанием состояния известно, что setBufferTimeout к малому значению (например, 5 мсек) обеспечит «лучшую» задержку. Каковы другие рекомендуемые значения конфигурации, которые следует учитывать...

У меня есть правильно работающая встроенная работа, и я хочу развернуть дополнительные совместные рабочие места. Эти недавно добавленные вакансии будут получать сообщения от старой работы и отправлять их в тему kafka. код, как показано ниже...

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

У меня есть таблица Metadata . Мне нужно содержимое таблицы в моем приложении Flink. Итак, я хочу прочитать все записи в таблице и сохранить в MapState<Metadata::Id, Metadata> . Если мое приложение перезапустится, я не хочу читать из...