API, который ожидает сообщения с помощью Spring-Kafka

Question

Я использую Spring Boot 2.0.7 и Spring-Kafka для создания шаблона запроса / ответа.В основном интерфейсный интерфейс пользователя делает запрос к API, который помещает сообщение в очередь запроса Kafka, сообщение обрабатывается внутренним процессом, а по завершении сообщение помещается в очередь ответа.

Я хочу предоставить интерфейсу интерфейса пользователя API, который ожидает готовности ответа.Пользовательский интерфейс в это время просто покажет сообщение обработки.Если ответ недоступен (например, через 2 минуты), API должен просто вернуть сообщение об отсутствии сообщения об ошибке, где мы можем дать пользователю указание вернуться позже.

Я немного новичок в Spring-Kafka,Позволяет ли мне создать опрос API?Если это так, любой пример кода будет очень цениться.

Answer 1

Это не так просто, как опрос темы для ответа, потому что вы должны сопоставлять запросы / ответы.

Вы можете использовать ReplyingKafkaTemplate.sendAndReceive() и продолжать проверять метод isDone() в Future<?>.

Если вы хотите опросить себя, вам придется создать потребительский объект из фабрики потребителей.