@Vladi_geras раз уж вы шарите, то мб какие мысли есть

на тему: вот допустим я хочу сделать кластер своих app к которым подключается конечный юзер. юзер может переключаться между app-ами - и ему интереснен поток данных (логично). как подключать app-ы к кафке чтобы на них не лить "паразитный" трафик, когда юзер переключается между нодами app-а? хотелось бы, конечно, чтобы кафка трекала shared app offset, но чот никак не придумаю как. проще говоря поток данных должен быть непрерывный и только на одну app в один момент времени

зачем усложнять. приложения работают, данные льются, они актуализированы, пусть юзер переключается между приложениями как обычно бывает, что набор бекенд приложений работают, обмениваются данными, а юзер работает напрямую с каким-то одним backend for frontend, например, где точка входа в систему идет, а остальные приложения же крутятся и поток данных продолжает работать или я не понял задачу до конца

ну при подключении юзера на app2 инстанс не хотелось бы чтобы app1 получал копию потока данных которую игнорил

app1, app2 разные приложения или инстансы одного и того же?

Инстансы, а юзер между ними может прыгать (ну например при обрыве коннекта)

если уж надо, может, как-то отключать консюмеров неактивных в данный момент инстансов но все же не понимаю зачем это надо в итоге ну есть у вас N инстансов приложении для надежности, ну выросла нагрузка на систему, добавились динамически новые инстансы autoscaling) нагрузка упала - лишние инстансы также упали, ну будет в итоге 2 активных, например

Это не про нагрузку, это про HA

я понимаю, это также и работает

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