FastKafka is a powerful and easy-to-use Python library for building asynchronous web services that interact with Kafka topics. Built on top of Pydantic, AIOKafka and AsyncAPI, FastKafka simplifies the process of writing producers and consumers for Kafka topics.
As a small possibly suggestion, perhaps to make possible fallback of being able to work on Sync stuff with process workers?
Recently tried FastAPI and was not fascinated that it works in anyio async engine which severely crippled celery working in a normal way. (Broken task discovery, not working global initialised stuff) Too many async engines around with no uniform compatibility to them.
Having option to run as sync / processes can be good idea for stability of usage for prod
As a small possibly suggestion, perhaps to make possible fallback of being able to work on Sync stuff with process workers?
Recently tried FastAPI and was not fascinated that it works in anyio async engine which severely crippled celery working in a normal way. (Broken task discovery, not working global initialised stuff) Too many async engines around with no uniform compatibility to them.
Having option to run as sync / processes can be good idea for stability of usage for prod
https://discordapp.com/channels/267624335836053506/366673702533988363/1086276920662040637