public T deserialize()

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()));
    }