Я хотел бы создать конечную точку REST в качестве фасада для хореографии сервисов, которые взаимодействуют друг с другом асинхронно.
В двух словах, интерфейс должен принять запрос REST, опубликовать сообщение в топику Кафки c и подождите, пока ответ не вернется в ответ топи c. Когда приходит ответ, он соотносит его с исходным запросом и отправляет (теперь снова синхронно) ответ клиенту.
Если ответ не попадает в ответ своевременно, то REST API возвращает ошибку.
Интересно, есть ли какие-либо предварительно созданные компоненты для обработки такого сценария. Спасибо вам всем!