FastStream is a powerful and easy-to-use Python framework for building asynchronous services interacting with event streams such as Apache Kafka, RabbitMQ, NATS and Redis.
This could be solved by writing a custom encoder/decoder that uses model_construct, please checkout Creating a custom encoder/decoder guide and see if this will fit your use-case
Data validation is sometimes not desirable due to negative performance impact
It would be useful if
fastkafka
provided a way to disable it using using model_construct.