Question on Avro serialization/deserialization

[calloncampbell]

Our team is considering using the Kafka extension from a Function App and we're wondering how Avro serialization exceptions are handled, as it's not clear in the source code. We're using the schema registry; however, there are situations where the wrong message is pushed to a Kafka stream, resulting in a serialization exception.

What would happen in this case when using the Kafka extension from an Azure Function app? Would the exception be caught in a try..catch block (C#), which would allow us to handle it accordingly?