java - 在 REST Web 服务内的请求/响应场景中使用 Kafka

Question

我目前正在构建一个 REST Web 服务，需要以请求/响应模式与 Kafka 进行通信。 (我知道 Kafka 并不是为此而设计的)。

1. 客户端调用 REST Web 服务。
2. REST Web 服务向 Kafka 发布消息
3. 在 Kafka 的另一端，应用程序使用消息并将响应发布回 Kafka
4. (与 #2 相同的请求内)REST Web 服务监听 Kakfa 并等待与请求对应的响应
5. REST Web 服务将响应返回给客户端

步骤 1 到 3 看起来很简单，但我在步骤 4 上遇到了困难。

我的想法是在每条消息中传播一个 ID，以便我可以检索与请求相对应的响应。

但是，我很难弄清楚如何在 REST Web 服务上设置监听器。监听器如何将消息返回给 Controller ？

Answer 1

我认为最好为每个用户创建一个主题，然后用户可以向另一个服务发送消息，这样的消息如下:

{
user:"myUserName"
data:"data of message"
}

然后服务只需要推送到主题“user.myUserName”然后从 Web 客户端只需订阅“user.myUserName”(使用消费者组配置，这仅用于只读最新消息)...

我认为最好的方法就是实现 websocket，然后通过这种方式推送/读取;)

再见，美好的一天。