Daniel Gellert

Have you tried setting PartitionAssignor when initializing the app? https://faust-streaming.github.io/faust/userguide/settings.html#partitionassignor

This is weird as [faust is also setting this assignor in a case where table standby replicas is set to zero](https://github.com/faust-streaming/faust/blob/master/faust/transport/drivers/aiokafka.py#L506-L510). If you do not need them can you try...

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...

The overall problem is that the api server is called and the connection is requested via API call. This endpoint only checks if there is one in the DB. If...

Looks like this is a waring from aiokafka: https://github.com/aio-libs/aiokafka/blob/c4b604062192d005cdcefb79eb6dbc717764c700/aiokafka/consumer/group_coordinator.py#L531-L535 It could have a variety of reasons this is happening. Can you share more detail about this error. Can you tweak...

This is just not something that is supported by Kafka. What you could do is writing a transport for this and delay message serialization. Or you do this in your...

Thank you @nucflash. @ArtemIlinArammeem unfortunatelly you are right and the issue IMO is much more fundamental than faust-streaming itself. The aiokafka lib also has seen no release in over a...

Do you have an example code? IMO the tables folder is populated if you define a Table `app.Table("name", key_serializer="str")` and also write to this table `table["John"] = 100` I do...

It's initialized regardless. This is expected. Do you have a hard blocker due to this?

+1