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.

Sign up for GitHub

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

Jump to bottom

fix(produce): Apply backpressure instead of crashing #281

Merged

lynnagara merged 2 commits into main from producer-buffer-error

Aug 31, 2023

Member

lynnagara commented Aug 18, 2023

If we get local queue full, let's raise MessageRejected to slow down the consumer.


          fix(produce): Apply backpressure instead of crashing

7a28935

If we get local queue full, let's raise MessageRejected to slow down
the consumer.

lynnagara requested a review from a team as a code owner

August 18, 2023 17:38

volokluev reviewed

View reviewed changes

Member

volokluev left a comment

Can we add a test for this?


          add test

3c3ff4c

untitaker approved these changes

View reviewed changes

lynnagara merged commit 01f55cb into main

8 checks passed

lynnagara deleted the producer-buffer-error branch

August 31, 2023 14:22

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

Labels

None yet