Следующий пример - уменьшенная версия моей проблемы, но ее должно быть достаточно, чтобы добраться до критической точки.
Давайте предположим, что у меня есть сообщения, которые я хочу преобразовать в канал somae.Теоретически это могут быть миллионы каналов.
Теперь у меня есть клиенты, которые могут отправлять сообщения на некоторый канал X, и клиенты, которые могут прослушивать сообщения на канале X (получить последнее и все последующие обновления).Эти клиенты взаимодействуют через HTTP (REST, websockets, gRPC) с бэкэндом.Для прослушивания идея состоит в том, чтобы использовать потоковую передачу по HTTP-соединениям (без опроса).
Итак, я могу отправлять сообщения в уникальные темы для каждого канала и распространять их через группы потребителей, но это, очевидно, не будет масштабироваться..
Можно ли еще достичь ТОЛЬКО с Кафкой?