Всем привет! Подскажите, пожалуйста, по стримам: допустим у меня есть

топик, в него сыпяться ивенты, поверх этого топика есть стрим с окном в 5 минут. Мне нужно, чтобы к этому окну доступ имело несколько инстансов приложения. При этом, мне важен порядок сообщений, поэтому партиция одна в топике. Правильно ли я понимаю, что GlobalTable мне здесь не поможет, и единственный вариант - давать стримам на инстансах разный applicationId?

стор внутри инстанса. Теоретически можно получить к нему доступ через Interactive Query но по моему это не правильно. Стримы параллелялят партишенами и соответственно разными инстансами

а нам не надо параллелить, нам наоборот нужно только чтобы несколько инстансов видели одно и тоже окно над стримом. А к GlobalTable получится из двух инстансов достучаться, если в топике только одна партиция?

Можно отдавать windowedKeystore . А вообще какая задача концептуально?

Почему не правильно?

UI нотификации через вебсокеты. Есть несколько инстансов аппа, которые держут коннекшны от вебсокетов, и есть топик, в который летят нотификаций. Хочется иметь возможность отправить нотификации, которые пришли, пока соединение с вебсокетом было разорвано (упал коннекшн и переконнектился через небольшое время). Иметь несколько партишнов не получится, потому что мы не знаем на каком именно инстансе аппа получатель нотификации, а значит должны слать на все. выглядит вообще как довольно стандартная задача, если без окна, а вот с ним чё-то не могу понять как лучше.

Можно и отдавать, если он не большой. Только вот состояние стора меняется по мере прихода мессаджей и как это трекать из другого инстанса. Вообще нужно конечно знать задачу

А коннекшены по инстансам как распределяются? Если можно сделать распределение по хешу ключа например то и продюсер может точно так-же роутить нотификейшены

произвольно распределяются, как кубер сроутит

тогда наверное лучше реализовать DLQ. Если не смог отослать то ложим нотификейшн в DLQ и потом пытаемся отослать позже

Порядок доставки сообщений конкретному клиенту важен