Class AvroDeserializer<T>

(async) Avro deserializer. Use this deserializer with GenericRecord, types generated using the avrogen.exe tool or one of the following primitive types: int, long, float, double, boolean, string, byte[].

Inheritance

object

AvroDeserializer<T>

Implements

IAsyncDeserializer<T>

Inherited Members

object.Equals(object)

object.Equals(object, object)

object.GetHashCode()

object.GetType()

object.MemberwiseClone()

object.ReferenceEquals(object, object)

object.ToString()

Namespace: Confluent.SchemaRegistry.Serdes

Assembly: Confluent.SchemaRegistry.Serdes.Avro.dll

Syntax

public class AvroDeserializer<T> : IAsyncDeserializer<T>

Type Parameters

Name	Description
T

Remarks

Serialization format: byte 0: Magic byte use to identify the protocol format. bytes 1-4: Unique global id of the Avro schema that was used for encoding (as registered in Confluent Schema Registry), big endian. following bytes: The serialized data.

Constructors

AvroDeserializer(ISchemaRegistryClient)

Declaration

public AvroDeserializer(ISchemaRegistryClient schemaRegistryClient)

Parameters

Type	Name	Description
ISchemaRegistryClient	schemaRegistryClient

AvroDeserializer(ISchemaRegistryClient, AvroDeserializerConfig, IList<IRuleExecutor>)

Declaration

public AvroDeserializer(ISchemaRegistryClient schemaRegistryClient, AvroDeserializerConfig config = null, IList<IRuleExecutor> ruleExecutors = null)

Parameters

Type	Name	Description
ISchemaRegistryClient	schemaRegistryClient
AvroDeserializerConfig	config
IList<IRuleExecutor>	ruleExecutors

AvroDeserializer(ISchemaRegistryClient, IEnumerable<KeyValuePair<string, string>>)

Initialize a new AvroDeserializer instance.

Declaration

public AvroDeserializer(ISchemaRegistryClient schemaRegistryClient, IEnumerable<KeyValuePair<string, string>> config = null)

Parameters

Type	Name	Description
ISchemaRegistryClient	schemaRegistryClient	An implementation of ISchemaRegistryClient used for communication with Confluent Schema Registry.
IEnumerable<KeyValuePair<string, string>>	config	Deserializer configuration properties (refer to AvroDeserializerConfig).

Methods

DeserializeAsync(ReadOnlyMemory<byte>, bool, SerializationContext)

Deserialize an object of type T from a byte array.

Declaration

public Task<T> DeserializeAsync(ReadOnlyMemory<byte> data, bool isNull, SerializationContext context)

Parameters

Type	Name	Description
ReadOnlyMemory<byte>	data	The raw byte data to deserialize.
bool	isNull	True if this is a null value.
SerializationContext	context	Context relevant to the deserialize operation.

Returns

Type	Description
Task<T>	A Task that completes with the deserialized value.

Implements

IAsyncDeserializer<T>