You signed in with another tab or window. Reload to refresh your session.You signed out in another tab or window. Reload to refresh your session.You switched accounts on another tab or window. Reload to refresh your session.Dismiss alert
Currently the micronaut gcp libraries utilise the MessageReceiver interface of the underlying Subscriber, unfortunately we are being hit by a bug in the pubsub libraries where duplicate messages are being sent even after something has been acknowledged - see https://issuetracker.google.com/330381101
The workaround we currently have is to switch the receiver used in DefaultSubscriberFactory to use a MessageReceiverWithAckResponse, but this is quite an intrusive modification of the framework, in particular when we use the reactive pubsub flows, as probably not implemented that part correctly.
What I would like to be able to do is choose either to use the default MessageReceiver, or the MessageReceiverWithAckResponse based off a config flag, but would also be ok if we need to implement our own extension of DefaultSubscriberFactory if it were able to expose some extension points.
The text was updated successfully, but these errors were encountered:
Feature description
Currently the micronaut gcp libraries utilise the MessageReceiver interface of the underlying Subscriber, unfortunately we are being hit by a bug in the pubsub libraries where duplicate messages are being sent even after something has been acknowledged - see https://issuetracker.google.com/330381101
The workaround we currently have is to switch the receiver used in DefaultSubscriberFactory to use a MessageReceiverWithAckResponse, but this is quite an intrusive modification of the framework, in particular when we use the reactive pubsub flows, as probably not implemented that part correctly.
What I would like to be able to do is choose either to use the default MessageReceiver, or the MessageReceiverWithAckResponse based off a config flag, but would also be ok if we need to implement our own extension of DefaultSubscriberFactory if it were able to expose some extension points.
The text was updated successfully, but these errors were encountered: