Контекст:
- Веб-сервер, который ежедневно получает миллионы HTTP-запросов. Конечно, должен быть проект (названный обработчиком), который отвечает за обработку этих запросов и отвечает на них некоторой информацией.
- Со стороны сервера я хотел бы использовать Kafka для извлечения из них некоторой информации и анализа ее в реальном времени (или каждый временной интервал).
Вопрос:
- как я могу использовать эти запросы как производитель Кафки?
- как создать клиента Kafka? (все эти данные нужно проанализировать, а затем вернуть, но Kafka — это «просто» система сообщений)
Некоторые фантазии:
A1.1 Может быть, я могу позволить «обработчику» проекта вызывать банку Kafka, тогда он может инициировать код производителя для отправки сообщения Kafka.
A1.2 Возможно, я могу создать другой проект, который прослушивает все HTTP-запросы на сервере, но на сервере есть другие HTTP-запросы.
Я пытался придумать много решений, но я не уверен в них, я хотел бы спросить ваших ребят, знали ли вы уже какие-то зрелые идеи или у вас есть идеи для реализации этого?