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

add batch processing for amqp consumers #470

Open
gfmio opened this issue Jul 22, 2020 · 0 comments
Open

add batch processing for amqp consumers #470

gfmio opened this issue Jul 22, 2020 · 0 comments

Comments

@gfmio
Copy link

gfmio commented Jul 22, 2020

Right now, amqp consumers only support handling one message at a time, while kafka consumers have a batch_size parameter.

Is it feasible to add batch processing for amqp consumers? Adapting the typing is slightly annoying, because the current handler function type expects a single message, but it's doable with overloading.

Or is there a reason I'm missing why the amqp consumer is only handler one message at a time right now?

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

No branches or pull requests

1 participant