There could be a few possible reasons why the Cloud Pub/Sub publish
function is becoming unresponsive when utilizing futures.wait
. Here are a few things to consider:
Incorrect usage of futures.wait
: futures.wait
is a method that blocks until all submitted futures are complete. If there is any misusage of the futures.wait
method, it could cause the publish
function to become unresponsive. Double-check to make sure you are correctly handling the return values from futures.wait
and that you are submitting the correct futures to the method.
Rate limiting: If you are publishing a large number of messages concurrently, there may be rate limiting occurring on the Pub/Sub API side. Check the error log to see if there are any rate limiting messages. If there are, try pacing your publishes to avoid hitting rate limits.
Network connectivity issues: If there are issues with network connectivity, it could cause the publish function to become unresponsive. Check to make sure your network settings are correct and the Pub/Sub API is accessible.
Code issues: There may be issues with the code itself that is causing the publish
function to become unresponsive. Check the error log to see if there are any exceptions being thrown or other error messages. Consider debugging the code to find and fix any issues.
Please start posting anonymously - your entry will be published after you log in or create a new account. This space is reserved only for answers. If you would like to engage in a discussion, please instead post a comment under the question or an answer that you would like to discuss
Asked: 2021-08-10 11:00:00 +0000
Seen: 17 times
Last updated: Jul 15 '21
What are the possible situations in which microservices can fail?
Why does DockerPush fail when attempting to upload from Jenkins to Jfrog Docker Registry?
What is the examination of the commands that are executed while running an application?
What is the issue with obtaining the URI in Android Fileprovider?
What is preventing me from adding new static files to my springboot web application?
What does the Maven error "Failure to transfer..." mean?
What can be the reason for the improper scaling of glyphs in my terminal emulator?
In my ReactJS application, I continuously encounter an error message that says "CANNOT GET/".
What causes communication issues in encoders that utilize the Can Open Protocol?
How can Kubernetes Ingress be associated with a 502 Bad Gateway error?