Is there a way to deserialize confluent avro for kafka messages but not at the source level? Process function?

Of course, just deserialize into something that’s a wrapper for raw byte arrays first and then you can use an actual Avro deserializer in a map/flatMap/process operator

Thanks for the quick answer, Yaroslav!