У меня есть сторонний API, который создает события через websocket.Как лучше всего прослушивать и распространять это событие в теме Кафки?
Моя стратегия такова:
- Кафка подключается к этому API и начинает прослушивать события.
- Когда происходит событие, Кафка распространяет это событие на все, что слушает эту тему.
Кафка будет использоваться как прокси для N API, распространяющихся на N подписчиков.
Как лучше всего это сделать?У Кафки есть какой нибудь разъем, который это позволяет?