Open santhh opened 6 years ago
Pub/Sub has a maximum request size limit. I think it's 10MB. Perhaps you are running into a "large messages + default batching settings -> message size too large."
On Tue, Jan 16, 2018 at 10:09 PM, santhh notifications@github.com wrote:
Hello: Thanks for making this project open for everyone! I am getting this error message when publishing to a topic. Payload is relatively big . Any idea what may be causing this?
Message Size: 1257 java.util.concurrent.ExecutionException: com.spotify.google.cloud. pubsub.client.RequestFailedException: 400 Bad Request at java.util.concurrent.CompletableFuture.reportGet( CompletableFuture.java:357) at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895)
I am using this method below. final List messageIds = pubsub.publish(PROJECT_ID, this.topic, messages).get();
— You are receiving this because you are subscribed to this thread. Reply to this email directly, view it on GitHub https://github.com/spotify/async-google-pubsub-client/issues/40, or mute the thread https://github.com/notifications/unsubscribe-auth/ARrMFhlUF1JFESq4BmpJcP7yDq_31zSiks5tLWRogaJpZM4Rgvr- .
-- Kir Titievsky | Product Manager | Google Cloud Pub/Sub https://cloud.google.com/pubsub/overview
Thank you! Figured! Changed this to smaller batches and it worked. Locally it works fine Although it’s failing in app engine because of access token issue . I posted another message in a thread. Seems like its a known issue?
Hello: Thanks for making this project open for everyone! I am getting this error message when publishing to a topic. Payload is relatively big . Any idea what may be causing this?
Message Size: 1257 java.util.concurrent.ExecutionException: com.spotify.google.cloud.pubsub.client.RequestFailedException: 400 Bad Request at java.util.concurrent.CompletableFuture.reportGet(CompletableFuture.java:357) at java.util.concurrent.CompletableFuture.get(CompletableFuture.java:1895)
I am using this method below. final List messageIds = pubsub.publish(PROJECT_ID, this.topic, messages).get();