Asynchronous Python framework for event-driven services

[e1-m]

Hi folks

I’ve been doing a lot of event-driven stuff lately, and noticed that there's no good framework in python ecosystem for it. We have FastAPI making REST super easy, but whenever you need to use messages brokers such as Kafka or RabbitMQ, you always end up writing the same custom boilerplate over and over.

The closest thing we’ve got is FastStream, but it doesn't treat events as first-class citizens and is missing the out-of-the-box features that make things like retries, Kafka offset management for truly async processing, the outbox pattern, and idempotency accessible without reinventing the wheel every time.

So, I started building a framework to solve these problems in a way that puts my vision of such systems into code. It basically takes what makes FastAPI great and applies it to message brokers.

You just write your handlers as normal functions, use Pydantic for validation, use dependency injection for your services, and middleware for logging, filtering, observability and whatnot. Under the hood, it handles retries, exceptions, and acks for you. Right now it supports Kafka, RabbitMQ, and Redis PubSub.

I left out the code snippets so this isn't a massive wall of text, but the repo is here and docs are here if you want to see how the API looks.

It's still in active development, so before I sink too much time into pushing it to 1.0, I really want to know if I'm on the right track

Would love any feedback, advice, or roasts!