-
Notifications
You must be signed in to change notification settings - Fork 181
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 support for RoundRobinAssignor #511
Comments
Faust can support using aiokafka's Try setting |
It is failing: |
same issue here |
Have you tried setting PartitionAssignor when initializing the app? https://faust-streaming.github.io/faust/userguide/settings.html#partitionassignor |
Still failing:
|
This is weird as faust is also setting this assignor in a case where table standby replicas is set to zero. If you do not need them can you try to set the setting If not you would need to build your own class that implements the interface of fausts PartitionAssignorT type |
I did and it works. But I opened this issue to solve it properly and not looking for a workaround because I cannot rely on it. |
I do not see an issue. faust says if you want to assign a PartitionAssignor your own you need to provide a PartitonAssignorT compatible class. RoundRobinPartitioner clearly isn't as it has no init function accepting the provided args of faust. Whats the issue in summary then? 🤔 |
My thoughts:
|
Checklist
master
branch of Faust.Expected behavior
I would like to use RoundRobinAssignor to distribute available partitions evenly across all consumers.
Actual behavior
Today Faust groups the same partition numbers onto the same consumers for all topics with the same number of partitions.
Versions
The text was updated successfully, but these errors were encountered: