目前，我正在使用aws-ebs微服务docker环境来部署用scala和akka编写的微服务。如果任何一个microservice docker崩溃并重新启动。在这种情况下，我们将丢失用户请求，并且服务将不会为这些情况返回任何响应。我当前的体系结构可以处理多达1000个并发请求而没有任何问题。为了避免这个问题，我计划使用kafka存储和检索所有请求和响应。
因此，我想使用kafka来管理所有web服务的请求和响应，并包含一个单独的服务或web套接字来处理所有请求并将响应再次存储到kafka。在本例中，如果我的核心进程docker崩溃或重新启动。它不会在任何时间丢失任何请求和响应。它将再次开始读取Kafka的请求并进行处理。
所有web服务都将请求存储在kafka的相关主题中，并从相关响应主题获取响应，然后返回到api响应。我在scalawebservices中找到了使用kafka的以下库。
https://github.com/akka/reactive-kafka/

请检查所附的架构图，我将使用它来有效地处理来自客户端应用程序的大量并发请求。这是一个好办法吗？我需要改变我的架构吗？
在对kafka和microservicedockers做了更多的研究之后，我创建了这个架构。如果这个建筑有什么问题，请告诉我。