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

Receives notification when rebalance in progress/assignments revoked #99

Open
Leesanwei opened this issue Jul 21, 2020 · 2 comments
Open

Comments

@Leesanwei
Copy link

Leesanwei commented Jul 21, 2020

Hi,
We are dealing with some scaling issues where if we have another consumer coming up in the same consumer group, we would like to delete some old cache.
In order to do this, we would need to receive a notification when a rebalance is in progress and we'll also have to know what partitions each consumer gets. Would this be possible?

Thanks!

@objectuser
Copy link
Contributor

That would definitely require some changes to Kaffe. 🤔 We'd be open to a PR on that. Not really even sure how to design it, but the notification might need to happen in either Kaffe.Subscriber or Kaffe.GroupMember.

@harshagelivi
Copy link

harshagelivi commented Feb 4, 2021

I am working on this for our use case. I made some changes and it seemed to work for us. Could someone please take a look at the PR - https://github.com/spreedly/kaffe/pull/108/files?

PS: This is the first time I'm working with Elixir and please don't mind if I made any obvious mistakes.

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