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

Google pubsub MessageStream should have option to be bounded. #186

Closed
AyWa opened this issue Aug 14, 2023 · 1 comment
Closed

Google pubsub MessageStream should have option to be bounded. #186

AyWa opened this issue Aug 14, 2023 · 1 comment

Comments

@AyWa
Copy link

AyWa commented Aug 14, 2023

Description

Right now, Subscription.subscribe create an async_channel::unbounded::<ReceivedMessage>(); which is working well, however, I think we should have an option to set the size of the channel.

I think there is high chance of OOM, if our google pubsub consumer is slower than the publisher. or if the publisher sometimes, submit a huge amount of data.

@damjankuznar
Copy link

@yoshidan has this issue been resolved and should be closed?

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

No branches or pull requests

3 participants