Прежде всего, я хочу поблагодарить того человека, который нашел время, чтобы прочитать, и предложить мне некоторое представление об этой трудности, с которой я сталкиваюсь.
В компании, в которой я работаю, мы реализуем несколько инновационных проектов с API-интерфейсами, которые будут использоваться внутри компании. Мы решили использовать Apache Kafka для организации очереди запросов пользователей. К сожалению, никто из нас ранее не знал Кафку, и все было связано с исследованиями.
Теперь, чтобы быть конкретным, мне нужно сотрудничество со следующим:
Мне нужно, чтобы, когда сервер источника делал запрос, сервер потребителя считывал его и в зависимости от запроса выполнял веб-службы, которые сгенерируют результат в формате JSON и вернут этот результат источнику.
До сих пор мне удалось установить связь между сервером-производителем и сервером-потребителем, но с помощью простых сообщений ... Примерно так:
введите описание изображения здесь
Вопросы:
- Как заставить потребителя в зависимости от моего запроса запускать веб-службы?
- Как заставить результат в формате JSON выполнения этих веб-служб быть возвращенным производителю? И в том же порядке, в котором были сделаны запросы?
Я очень ценю сотрудничество, эта тема меня смущает.
Спасибо!