Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Alpakka: google-cloud-pub-sub - One subscriber consuming 60% of messages #2937

Open
rlupo06 opened this issue Nov 8, 2022 · 0 comments
Open

Comments

@rlupo06
Copy link

rlupo06 commented Nov 8, 2022

Summary:

I have an application (subscriber) that I'm scaling to 4 instances. All 4 instances are subscribers of one subscription. For some reason 1 of those instances is consuming 60% of messages on the Pub/Sub subscription (300k+ small messages on pubsub's subscription) and the other 3 are consuming about 13% each. I believe the latency of the instance consuming 60% of messages is high and I believe if I could get all 4 instances consuming a similar percentages I could increase throughput.

My application uses version 1.1.2 of the akka-stream-alpakka-google-cloud-pub-sub library which communicates to Pub/Sub through HTTP requests NOT gRPC. I've read through the release notes of the newer versions of that library and there's no mention of a change that would fix what I am seeing.

Question:
Thoughts on how to get messages distributed more equally among the subscribers and any explanation on why one of the instances is consuming a much larger portion of the messages?

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Projects
None yet
Development

No branches or pull requests

2 participants