FastAPI WebSocket + Kafka: только последний подключенный клиент получает сообщения ⇐ Python

[Anonymous]

Я создаю панель мониторинга в реальном времени, используя FastAPI WebSockets + Kafka. Все работает отлично для одного пользователя, но при подключении нескольких пользователей сообщения получает только последний подключавшийся пользователь.
Поведение:

• Первый пользователь открывает панель управления - получает оповещения ✓
• Второй пользователь открывает панель управления - первый пользователь перестает получать сообщения, только второй пользователь получает сообщения
• Второй пользователь закрывает соединение - первый пользователь внезапно начинает получать снова

Похоже, что сообщения Kafka передаются только одному соединению WebSocket за раз, а не транслируются всем подключенным клиентам.
Кто-нибудь сталкивался с этим? Как правильно обрабатывать несколько клиентов WebSocket, использующих одну и ту же тему Kafka?

Подробнее здесь: https://stackoverflow.com/questions/798 ... s-messages