FastKafka – A Free Open-Source Python Library for Building Kafka-Based Services
1–4 of 4 posts
Re: FastKafka – A Free Open-Source Python Library for Building Kafka-Based Services
#2FastKafka is a new open-source software available on GitHub under the Apache 2 license that simplifies the process of writing producers and consumers for Kafka topics. Inspired by FastAPI, FastKafka uses the same paradigms for routing, validation, and documentation, making it easy to learn and integrate into your existing projects.
Built on top of Pydantic, AIOKafka, and AsyncAPI, FastKafka handles all the parsing, networking, task scheduling, and documentation generation automatically, making it an ideal choice for developers looking to streamline their workflow and accelerate their projects.
With FastKafka, you can quickly prototype and develop high-performance Kafka-based services with minimal code. And, because it's open-source, you can use it in your projects for free and contribute to its development if you'd like.
We're excited to announce the release of FastKafka and invite you to test the tool and provide feedback for making it better. Visit the GitHub repository to get started, and don't hesitate to reach out to the FastKafka team with any questions or suggestions.
Re: FastKafka – A Free Open-Source Python Library for Building Kafka-Based Services
#3It looks incredible and I truly hope your project takes off for my sake since I have to work with Kafka from time to time!
I had a quick look through the code snippets and docs so maybe I missed it, what happens if the message received on the topic doesn't match the pydantic model? Is there an error handler or callback?
Re: FastKafka – A Free Open-Source Python Library for Building Kafka-Based Services
#4It looks incredible and I truly hope your project takes off for my sake since I have to work with Kafka from time to time! I had a quick look through the code snippets and docs so maybe I missed it, what happens if the message received on the topic doesn't match the pydantic model? Is there an error handler or callback?
Thanks for the support :)
Right now, we just log the error but we can implement a callback easily. I’ll create an issue and it should be implemented in the next release in two weeks.