我计划开发一个应用程序，可以通过使用 REST 客户端（SpringBoot REST）发出请求，例如获取基于地理代码的各种可用服务的列表。
我将此请求作为消息发布给 Kafka。有一个消费者（Python 代码）侦听此消息，并在消息到达时查找各种存储（NoSQL/HDFS），并获取服务列表。
我已经将这个概念工作到我收到请求、使用它并产生结果的地步。
不确定的地方是 RestController/RestService 如何知道聚合何时完成并准备好结果，以便它可以将响应连同总大小一起发送回浏览器？
请对此有任何想法建议吗？