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? -- >>>>>>>>>> Read the docs: http://akka.io/docs/ >>>>>>>>>> Check the FAQ: >>>>>>>>>> http://doc.akka.io/docs/akka/current/additional/faq.html >>>>>>>>>> Search the archives: https://groups.google.com/group/akka-user --- You received this message because you are subscribed to the Google Groups "Akka User List" group. To unsubscribe from this group and stop receiving emails from it, send an email to [email protected]. To post to this group, send email to [email protected]. Visit this group at https://groups.google.com/group/akka-user. For more options, visit https://groups.google.com/d/optout.
