Tengo un servicio (llamémoslo Servicio A) que utiliza Akka Server HTTP para manejar las solicitudes entrantes. También tengo una aplicación de terceros (Servicio B) que proporciona varios servicios web. El propósito del servicio A es transformar las solicitudes de los clientes, llamar a uno o múltiples servicios web del servicio B, fusionar / transformar resultados y devolverlos a un cliente.

Estoy usando Actores para algunas partes, y solo Future para otras. Para hacer una llamada al Servicio B, utilizo el cliente Akka HTTP.

Http.get(actorSystem).singleRequest(HttpRequest.create()
        .withUri("http://127.0.0.1:8082/test"), materializer)
        .onComplete(...)

El problema es que se crea un nuevo flujo por cada solicitud de Servicio A, y si hay varias conexiones concurrentes, se produceakka.stream.OverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32] error

Ya hice esta pregunta y recibí una sugerencia para usar un solo Flow¿Cómo llamar correctamente al cliente HTTP de Akka para múltiples solicitudes (10k - 100k)?

Si bien funciona para un lote de solicitudes provenientes de un solo lugar, no sé cómo usar un solo Flow de todos mis controladores de solicitudes simultáneas.

¿Cuál es la "forma Akka" correcta para hacerlo?