AsyncSchemaRegistryDeserializer<T> class

An IAsyncDeserializer<> that resolves Avro schemas on the fly. When deserializing messages, this deserializer will attempt to derive a schema ID from the first five bytes. (For more information, see the Confluent wire format documentation.) If a schema with that ID is not found in cache, it will attempt to pull down a matching schema from the Schema Registry.
AssemblyChr.Avro.Confluent
NamespaceChr.Avro.Confluent
Signature
public class AsyncSchemaRegistryDeserializer<T> : Confluent.Kafka.IAsyncDeserializer<T>, IDisposable
Baseobject
InterfacesIAsyncDeserializer<T>
IDisposable

Constructors

AsyncSchemaRegistryDeserializer(ISchemaRegistryClient, IBinaryDeserializerBuilder, IJsonSchemaReader, TombstoneBehavior)
Creates a deserializer.
AsyncSchemaRegistryDeserializer(IEnumerable<KeyValuePair<string>>, IBinaryDeserializerBuilder, IJsonSchemaReader, TombstoneBehavior)
Creates a deserializer.

Properties

IBinaryDeserializerBuilder DeserializerBuilder
The deserializer builder used to generate deserialization functions for C# types.
ISchemaRegistryClient RegistryClient
The client used for Schema Registry operations.
IJsonSchemaReader SchemaReader
The JSON schema reader used to convert schemas received from the registry into abstract representations.
TombstoneBehavior TombstoneBehavior
The behavior of the deserializer on tombstone records.

Methods

Task<T> DeserializeAsync(ReadOnlyMemory<byte>, bool, SerializationContext)
Deserialize a message. (See DeserializeAsync(ReadOnlyMemory<byte>, bool, SerializationContext).)
void Dispose()
Disposes the deserializer, freeing up any resources.
void Dispose(bool)
Disposes the deserializer, freeing up any resources.
Chr.Avro