Hi!
Thank you for your reply.
I was thinking it can be a flow control issue, so I've been logging the
time between the arrival of the message at the subscriber and the time the
subscriber acknowledges it and that is usually not more than 1 second.
Nevertheless, I'll try the flow control is the problem persists.
Thanks!
On Thursday, 2 August 2018 10:47:44 UTC+3, Roxana Ioana Mirel wrote:
>
> Hello,
>
> I have a GKE cluster with three nodes, which are being subscribers to the
> same PubSub subscription
> and polling continuously for new messages.
> I am using the Asynchronous Pull mechanism for my subscribers. These are
> running in a NodeJS Express application.
>
> subscription.on("message", message => messageHandler(message));
>
> async function messageHandler(message) {
> try {
> await doSomeProcessing();
> message.ack();
> } catch (error) {
> if (error instanceof DuplicateRowError) {
> message.ack();
> } else {
> console.log(`Message ${message.id} was not acknowledged. Waiting to
> be sent again.`);
> }
> }
> }
>
> Things go well most of the time, but from time to time the subscribers
> stop receiving messages. Redeploying the application doesn't help and they
> recover by themselves after aprox 30min- 1 hour, when the pending
> messages are being sent. The quota has not been exceeded and
> subscription.on("error",
> error ..) does not get triggered, the StackDriver logs also don't show
> any errors.
>
> Any idea what might cause this pb?
>
--
You received this message because you are subscribed to the Google Groups
"Google App Engine" group.
To unsubscribe from this group and stop receiving emails from it, send an email
to google-appengine+unsubscr...@googlegroups.com.
To post to this group, send email to google-appengine@googlegroups.com.
Visit this group at https://groups.google.com/group/google-appengine.
To view this discussion on the web visit
https://groups.google.com/d/msgid/google-appengine/e50f78a6-a0e6-456d-a421-6cb0143ced7f%40googlegroups.com.
For more options, visit https://groups.google.com/d/optout.
