I am trying to produce Avro-encoded messages to Kafka using PySpark Structured Streaming. My schema is registered in the Confluent Schema Registry. However, I encounter an InvalidRecordException when the schema validation is turned on.