Библиотека для Apache Flink, которая синхронизирует побочные потоки данных со стейтом, чтобы избежать тихих ошибок при холодном старте.
Библиотека для Apache Flink решает проблему холодного старта: основной поток данных начинает обрабатываться раньше, чем в state загрузятся справочные данные из другого топика (правила, списки участников), из-за чего задание молча выдаёт неверные результаты. flink-bullseye удерживает основной поток до полной синхронизации, затем отпускает его и повторяет проверку через заданный интервал. Работает с Flink 1.20 на Java, есть отдельный модуль для Kafka.
Описание автора:Periodic re-sync barrier for keyed-state side inputs in Apache Flink DataStream jobs
