in csharp/avro/src/KafkaAvroDeserializer.cs [46:68]
public T Deserialize(ReadOnlySpan<byte> data, bool isNull, SerializationContext context)
{
if (data.IsEmpty)
{
return default(T);
}
BinaryContent content = new BinaryContent
{
Data = new BinaryData(data.ToArray()),
};
if (context.Headers.TryGetLastBytes("content-type", out var headerBytes))
{
content.ContentType = Encoding.UTF8.GetString(headerBytes);
}
else
{
content.ContentType = string.Empty;
}
return serializer.Deserialize<T>(content);
}