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.
Also, how can I skip a commit if a critical error has occurred? I would like this message to return in the topic and be read, for example, after a restart. It would be cool if the problem of message loss was solved.
Originally posted by @fangorntreabeard in https://github.com/airtai/fastkafka/discussions/138#discussioncomment-5372172