use pause/resume to implement queues with priority #2835
whateverwhocares
started this conversation in
Ideas
Replies: 0 comments
Sign up for free
to join this conversation on GitHub.
Already have an account?
Sign in to comment
-
Maybe it doesn't work as I don't see any packages implement priority queues based on kafka, and even no much pages talking about this (sure I didn't pay too much time on searching...). But why don't add this support via the pause/resume api on ConsumerGroup? Say there are two topics A and B, if there is msg from topic B, then A will be paused so that the consumerGroup will focus all the cpu on handling of topic A, after the msg from B are processed, then B can be resumed; I did some simple demo, looks it works, but not sure why it's not added to Sarama or any other package? Anyone knows why?
Beta Was this translation helpful? Give feedback.
All reactions