I have a flow that creates request objects and then issues them using singleRequest. The flow works fine, however, I encounter
Response exception: akka.stream.BaseOverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32]
Response exception: akka.stream.BaseOverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32]
Response exception: akka.stream.BaseOverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32]
Response exception: akka.stream.BaseOverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32]
Response exception: akka.stream.BaseOverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32]
Response exception: akka.stream.BaseOverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32]
Response exception: akka.stream.BaseOverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32]
Response exception: akka.stream.BaseOverflowStrategy$Fail$BufferOverflowException: Exceeded configured max-open-requests value of [32]
...
exceptions when pumping a large number of single requests through my flow, and hence a large number of "singleRequest" calls. Obviously, I could increase the configured amount, but its possible that I need to issue hundreds of single requests and could be quite variable so I could never set the amount to be large enough since I don't know the maximum value ahead of time.
I though that the underlying connection pool would have back pressure that bubbles up and keeps the request "queued" until a slot opens for the request to be executed, and hence, complete my future result returned from singleRequest once it is run.
But I am getting these errors so this does not appear to work the way I thought it would.
Do I need to configure my flow differently and have it be aware of the max-open-request limit in some way?