I'm trying to produce messages to a kafka topic using the PublishKafkaRecord_0_11 processor. We are also using a confluent schema registry with a schema for both the value and the key. The configurations are attached. The issue is that our scala consumer isn't able to deserialize the messages due to the message keys not being properly avro encoded with the schema registry. The message values appear to be serialized properly. Is there an easy way to use the schema registry to encode the message keys as an avro record? ... View more