in java/avro/src/main/java/com/microsoft/azure/schemaregistry/kafka/avro/KafkaAvroDeserializer.java [96:110]
public T deserialize(String topic, Headers headers, byte[] bytes) {
MessageContent message = new MessageContent();
message.setBodyAsBinaryData(BinaryData.fromBytes(bytes));
Header contentTypeHeader = headers.lastHeader("content-type");
if (contentTypeHeader != null) {
message.setContentType(new String(contentTypeHeader.value()));
} else {
message.setContentType("");
}
return (T) this.serializer.deserialize(
message,
TypeReference.createInstance(this.config.getAvroSpecificType()));
}