带有事件驱动编排的REST命令

Question

我试图以事件驱动的架构风格设计一个系统，还试图公开REST以发送命令/查询。我决定用卡夫卡做消息经纪人。我正在设计的舞蹈编排如下：

​

对我来说非常模糊的部分是如何实现事件连接：

1. 计费-只有当用户收到用户创建事件(1)并且帐户已经创建(2)时，服务才应该开始创建用户。
2. api-网关只应在帐户和计费服务完成处理后才将结果返回给客户(2和3)。

我知道我可以在客户端使用其他协议(例如WebSockets)，但我不喜欢这样做，因为我需要向第三方公开这样的API。我还可以进行异步客户端调用和轮询，以检查请求是否已经完成，但管理起来似乎非常复杂。建议的实现这种互动的方式是什么？

附注：我正在使用Spring和。

Answer 1

客户端的请求/回复消息可以使用spring云流，但它涉及到一些问题，因为它不是为此而设计的，它是用于单向流处理的。

最好在客户端使用spring (ReplyingKafkaTemplate)或(出站网关)进行请求/回复。

在服务端，您可以使用@StreamListener (spring流)、@KafkaListener或春季集成入站网关。