Skip to content

fix: check batch size before re-queueing retried messages #2027

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

Open
wants to merge 3 commits into
base: main
Choose a base branch
from

Conversation

1kilobit
Copy link

@1kilobit 1kilobit commented Apr 16, 2025

Fixes #2026 🦕

This adds the same batch size-based flushing logic added to MessageQueue.add() in PR #1963 to MessageQueue.handleRetry(), which also queues into the next batch.

@1kilobit 1kilobit requested review from a team as code owners April 16, 2025 22:22
Copy link

google-cla bot commented Apr 16, 2025

Thanks for your pull request! It looks like this may be your first contribution to a Google open source project. Before we can look at your pull request, you'll need to sign a Contributor License Agreement (CLA).

View this failed invocation of the CLA check for more information.

For the most up to date status, view the checks section at the bottom of the pull request.

@product-auto-label product-auto-label bot added size: s Pull request size is small. api: pubsub Issues related to the googleapis/nodejs-pubsub API. labels Apr 16, 2025
@feywind
Copy link
Collaborator

feywind commented May 8, 2025

@1kilobit Thanks for the PR, I just noticed that I missed this!

Sign up for free to join this conversation on GitHub. Already have an account? Sign in to comment
Labels
api: pubsub Issues related to the googleapis/nodejs-pubsub API. size: s Pull request size is small.
Projects
None yet
Development

Successfully merging this pull request may close these issues.

Retried ack requests are re-queued without respecting batch limits
2 participants