FastStream (https://github.com/airtai/faststream) simplifies the process of writing producers and consumers for message queues, handling all the parsing, networking and documentation generation automatically. It is a new package based on the ideas and experiences gained from FastKafka and Propan. By joining our forces, we picked up the best from both packages and created a unified way to write services capable of processing streamed data regardless of the underlying protocol. We'll continue to maintain both packages, but new development will be in this project.

Making streaming microservices has never been easier. Designed with junior developers in mind, FastStream simplifies your work while keeping the door open for more advanced use cases. Here's a look at the core features that make FastStream a go-to framework for modern, data-centric microservices.

  - Multiple Brokers: FastStream provides a unified API to work across multiple message brokers (Apache Kafka, RabbitMQ, NATS and Redis)
  - Pydantic Validation: Leverage Pydantic's validation capabilities to serialize and validate incoming messages
  - Automatic Docs: Stay ahead with automatic AsyncAPI documentation
  - Intuitive: Full-typed editor support makes your development experience smooth, catching errors before they reach runtime
  - Powerful Dependency Injection System: Manage your service dependencies efficiently with FastStream's built-in DI system
  - Testable: Supports in-memory tests, making your CI/CD pipeline faster and more reliable
  - Extendable: Use extensions for lifespans, custom serialization and middleware
  - Integrations: FastStream is fully compatible with any HTTP framework you want (FastAPI especially)
  - Observability: Add OpenTelemetry or Prometheus support to your services.