It 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?