alexakra

Results 4 comments of alexakra

It is failing: `[ERROR] [^-App]: Crashed reason=AttributeError("type object 'RoundRobinPartitionAssignor' has no attribute 'assigned_standbys'")` I think that there is no `assignor` field on `App`.

> Have you tried setting PartitionAssignor when initializing the app? https://faust-streaming.github.io/faust/userguide/settings.html#partitionassignor Still failing: `app = App(..., PartitionAssignor=RoundRobinPartitionAssignor)` > File "../lib/python3.11/site-packages/mode/services.py", line 807, in _default_start > await self._actually_start() > File "../lib/python3.11/site-packages/mode/services.py",...

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.

My thoughts: 1. Faust internally uses RoundRobinPartitioner which is not `PartitonAssignorT` compatible class. Why is it so? 2. This is a common use case where many would like to use...