FastStream releases a new minor version 0.4.0 today
This release adds support for Confluent's Python Client for Apache Kafka™. Confluent's Python Client for Apache Kafka does not natively support async functions, and its integration with modern async-based services is a bit trickier. That was the reason why our initial support for Kafka broker used aiokafka. However, that choice was less fortunate as it is not as well maintained as the Confluent version. After receiving numerous requests, we finally decided to bite the bullet and create an async wrapper around Confluent's Python Client and add full support for it in FastStream.
This release adds support for Confluent's Python Client for Apache Kafka™. Confluent's Python Client for Apache Kafka does not natively support async functions, and its integration with modern async-based services is a bit trickier. That was the reason why our initial support for Kafka broker used aiokafka. However, that choice was less fortunate as it is not as well maintained as the Confluent version. After receiving numerous requests, we finally decided to bite the bullet and create an async wrapper around Confluent's Python Client and add full support for it in FastStream.
You can find the release here - https://github.com/airtai/faststream/releases/tag/0.4.0
Please take a look at it, play with it, and if you are satisfied, then go ahead use it in your projects: https://faststream.airt.ai/0.4/confluent/