java - Spring 启动: Rest endpoint integration with Kafka

Question

正在处理必须将消息发送到另一个服务进行处理的休息端点。它是一个微服务架构，所有服务都通过Kafka消息代理连接。

Spring 支持异步方法的@Async，但它无法按预期工作。代码类似于

@RequestMapping(method = RequestMethod.GET, value = "/responses/{id}", produces = "application/json")
@Async
public CompletableFuture<Response> getResponseById(@PathVariable @Valid Long id) {
  //some code
  producer.send(id);
  //other service will send the response back and kafka consumer will save it to the db
  responseRepository.findById(id);
}

它不会等待消息从 kafka 返回。

这里缺少什么？

Answer 1

尝试使用sync(blocking)方法发送消息生产者.send(id).get();这将使执行等待结果。